From 81bdf0b8892a15e668db8a7ddf3f1f25db26a291 Mon Sep 17 00:00:00 2001 From: Jinhe Zhang Date: Tue, 29 Jul 2025 12:18:38 -0400 Subject: [PATCH] MINOR: Remove duplicated code in PgeViewDemo (#20252) Remove the default implementation Reviewers: Lucas Brutschy --- .../pageview/PageViewUntypedDemo.java | 21 ------------------- 1 file changed, 21 deletions(-) diff --git a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java index 6225793cde1..ba9b498b8f3 100644 --- a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java +++ b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java @@ -40,7 +40,6 @@ import com.fasterxml.jackson.databind.node.ObjectNode; import java.io.IOException; import java.time.Duration; -import java.util.Map; import java.util.Properties; /** @@ -64,11 +63,6 @@ public class PageViewUntypedDemo { public static class JsonNodeSerializer implements Serializer { private final ObjectMapper objectMapper = new ObjectMapper(); - @Override - public void configure(final Map configs, final boolean isKey) { - // No configuration needed - } - @Override public byte[] serialize(final String topic, final JsonNode data) { if (data == null) { @@ -80,11 +74,6 @@ public class PageViewUntypedDemo { throw new SerializationException("Error serializing JSON message", e); } } - - @Override - public void close() { - // No resources to close - } } /** @@ -93,11 +82,6 @@ public class PageViewUntypedDemo { public static class JsonNodeDeserializer implements Deserializer { private final ObjectMapper objectMapper = new ObjectMapper(); - @Override - public void configure(final Map configs, final boolean isKey) { - // No configuration needed - } - @Override public JsonNode deserialize(final String topic, final byte[] data) { if (data == null) { @@ -109,11 +93,6 @@ public class PageViewUntypedDemo { throw new SerializationException("Error deserializing JSON message", e); } } - - @Override - public void close() { - // No resources to close - } } public static void main(final String[] args) throws Exception {