4040
4141import java .io .IOException ;
4242import java .time .Duration ;
43- import java .util .Map ;
4443import java .util .Properties ;
4544
4645/**
@@ -64,11 +63,6 @@ public class PageViewUntypedDemo {
6463 public static class JsonNodeSerializer implements Serializer <JsonNode > {
6564 private final ObjectMapper objectMapper = new ObjectMapper ();
6665
67- @ Override
68- public void configure (final Map <String , ?> configs , final boolean isKey ) {
69- // No configuration needed
70- }
71-
7266 @ Override
7367 public byte [] serialize (final String topic , final JsonNode data ) {
7468 if (data == null ) {
@@ -80,11 +74,6 @@ public byte[] serialize(final String topic, final JsonNode data) {
8074 throw new SerializationException ("Error serializing JSON message" , e );
8175 }
8276 }
83-
84- @ Override
85- public void close () {
86- // No resources to close
87- }
8877 }
8978
9079 /**
@@ -93,11 +82,6 @@ public void close() {
9382 public static class JsonNodeDeserializer implements Deserializer <JsonNode > {
9483 private final ObjectMapper objectMapper = new ObjectMapper ();
9584
96- @ Override
97- public void configure (final Map <String , ?> configs , final boolean isKey ) {
98- // No configuration needed
99- }
100-
10185 @ Override
10286 public JsonNode deserialize (final String topic , final byte [] data ) {
10387 if (data == null ) {
@@ -109,11 +93,6 @@ public JsonNode deserialize(final String topic, final byte[] data) {
10993 throw new SerializationException ("Error deserializing JSON message" , e );
11094 }
11195 }
112-
113- @ Override
114- public void close () {
115- // No resources to close
116- }
11796 }
11897
11998 public static void main (final String [] args ) throws Exception {
0 commit comments