From aa9d59fa93178f40797a8bb3716dd0a30594833f Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 9 Jun 2024 20:36:56 +0200 Subject: [PATCH] top10: 1.2.1 - Simplified serialization configuration --- .../kafka/wordcount/top10/Top10ApplicationConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/de/juplo/kafka/wordcount/top10/Top10ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/wordcount/top10/Top10ApplicationConfiguration.java index 5e56066..255f0e4 100644 --- a/src/main/java/de/juplo/kafka/wordcount/top10/Top10ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/wordcount/top10/Top10ApplicationConfiguration.java @@ -34,6 +34,7 @@ public class Top10ApplicationConfiguration props.put(StreamsConfig.APPLICATION_ID_CONFIG, properties.getApplicationId()); props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, properties.getBootstrapServer()); + if (properties.getCommitInterval() != null) props.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, properties.getCommitInterval()); if (properties.getCacheMaxBytes() != null) @@ -50,7 +51,6 @@ public class Top10ApplicationConfiguration props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, JsonSerde.class.getName()); props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, JsonSerde.class.getName()); - props.put(JsonDeserializer.TRUSTED_PACKAGES, Top10Application.class.getPackageName()); props.put(JsonDeserializer.KEY_DEFAULT_TYPE, User.class.getName()); props.put(JsonDeserializer.VALUE_DEFAULT_TYPE, Ranking.class.getName()); props.put( -- 2.20.1