|
1 | | -package com.provectus.kafka.ui.serdes.smile; |
| 1 | +package io.kafbat.serde.smile; |
2 | 2 |
|
3 | 3 | import com.fasterxml.jackson.core.JsonProcessingException; |
4 | 4 | import com.fasterxml.jackson.databind.JsonNode; |
|
7 | 7 | import com.fasterxml.jackson.dataformat.smile.SmileGenerator; |
8 | 8 | import com.fasterxml.jackson.dataformat.smile.SmileParser; |
9 | 9 | import com.fasterxml.jackson.dataformat.smile.databind.SmileMapper; |
10 | | -import com.provectus.kafka.ui.serde.api.DeserializeResult; |
11 | | -import com.provectus.kafka.ui.serde.api.PropertyResolver; |
12 | | -import com.provectus.kafka.ui.serde.api.RecordHeaders; |
13 | | -import com.provectus.kafka.ui.serde.api.SchemaDescription; |
14 | | -import com.provectus.kafka.ui.serde.api.Serde; |
| 10 | +import io.kafbat.ui.serde.api.DeserializeResult; |
| 11 | +import io.kafbat.ui.serde.api.PropertyResolver; |
| 12 | +import io.kafbat.ui.serde.api.SchemaDescription; |
| 13 | +import io.kafbat.ui.serde.api.Serde; |
15 | 14 | import java.io.IOException; |
16 | 15 | import java.util.Collections; |
17 | 16 | import java.util.Optional; |
@@ -59,32 +58,26 @@ public boolean canSerialize(String topic, Target target) { |
59 | 58 |
|
60 | 59 | @Override |
61 | 60 | public Serializer serializer(String topic, Target target) { |
62 | | - return new Serializer() { |
63 | | - @Override |
64 | | - public byte[] serialize(String inputString) { |
65 | | - try { |
66 | | - JsonNode jsonNode = JSON_MAPPER.readTree(inputString); |
67 | | - return smileMapper.writeValueAsBytes(jsonNode); |
68 | | - } catch (JsonProcessingException e) { |
69 | | - throw new RuntimeException("Serialization error", e); |
70 | | - } |
| 61 | + return inputString -> { |
| 62 | + try { |
| 63 | + JsonNode jsonNode = JSON_MAPPER.readTree(inputString); |
| 64 | + return smileMapper.writeValueAsBytes(jsonNode); |
| 65 | + } catch (JsonProcessingException e) { |
| 66 | + throw new RuntimeException("Serialization error", e); |
71 | 67 | } |
72 | 68 | }; |
73 | 69 | } |
74 | 70 |
|
75 | 71 | @Override |
76 | 72 | public Deserializer deserializer(String topic, Target target) { |
77 | | - return new Deserializer() { |
78 | | - @Override |
79 | | - public DeserializeResult deserialize(RecordHeaders recordHeaders, byte[] bytes) { |
80 | | - try { |
81 | | - return new DeserializeResult( |
82 | | - smileMapper.readTree(bytes).toString(), |
83 | | - DeserializeResult.Type.JSON, |
84 | | - Collections.emptyMap()); |
85 | | - } catch (IOException e) { |
86 | | - throw new RuntimeException("Deserialization error", e); |
87 | | - } |
| 73 | + return (recordHeaders, bytes) -> { |
| 74 | + try { |
| 75 | + return new DeserializeResult( |
| 76 | + smileMapper.readTree(bytes).toString(), |
| 77 | + DeserializeResult.Type.JSON, |
| 78 | + Collections.emptyMap()); |
| 79 | + } catch (IOException e) { |
| 80 | + throw new RuntimeException("Deserialization error", e); |
88 | 81 | } |
89 | 82 | }; |
90 | 83 | } |
|
0 commit comments