40
40
41
41
import java .io .IOException ;
42
42
import java .time .Duration ;
43
- import java .util .Map ;
44
43
import java .util .Properties ;
45
44
46
45
/**
@@ -64,11 +63,6 @@ public class PageViewUntypedDemo {
64
63
public static class JsonNodeSerializer implements Serializer <JsonNode > {
65
64
private final ObjectMapper objectMapper = new ObjectMapper ();
66
65
67
- @ Override
68
- public void configure (final Map <String , ?> configs , final boolean isKey ) {
69
- // No configuration needed
70
- }
71
-
72
66
@ Override
73
67
public byte [] serialize (final String topic , final JsonNode data ) {
74
68
if (data == null ) {
@@ -80,11 +74,6 @@ public byte[] serialize(final String topic, final JsonNode data) {
80
74
throw new SerializationException ("Error serializing JSON message" , e );
81
75
}
82
76
}
83
-
84
- @ Override
85
- public void close () {
86
- // No resources to close
87
- }
88
77
}
89
78
90
79
/**
@@ -93,11 +82,6 @@ public void close() {
93
82
public static class JsonNodeDeserializer implements Deserializer <JsonNode > {
94
83
private final ObjectMapper objectMapper = new ObjectMapper ();
95
84
96
- @ Override
97
- public void configure (final Map <String , ?> configs , final boolean isKey ) {
98
- // No configuration needed
99
- }
100
-
101
85
@ Override
102
86
public JsonNode deserialize (final String topic , final byte [] data ) {
103
87
if (data == null ) {
@@ -109,11 +93,6 @@ public JsonNode deserialize(final String topic, final byte[] data) {
109
93
throw new SerializationException ("Error deserializing JSON message" , e );
110
94
}
111
95
}
112
-
113
- @ Override
114
- public void close () {
115
- // No resources to close
116
- }
117
96
}
118
97
119
98
public static void main (final String [] args ) throws Exception {
0 commit comments