From e8fd3ee0e4ca8e710565f6431811c240c60dbd71 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 2 Feb 2025 18:49:06 +0100 Subject: [PATCH] =?utf8?q?Vorlage=20f=C3=BCr=20das=20Empfangen=20von=20Nac?= =?utf8?q?hrichten=20aus=20einer=20geteilten=20Lib?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- .../de/juplo/kafka/ApplicationConfiguration.java | 7 +++---- src/main/java/de/juplo/kafka/ExampleConsumer.java | 14 +++++++------- 2 files changed, 10 insertions(+), 11 deletions(-) diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index 1d8c9162..71f258b3 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -5,7 +5,6 @@ import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.KafkaConsumer; import org.apache.kafka.clients.consumer.StickyAssignor; import org.apache.kafka.common.serialization.StringDeserializer; -import org.springframework.kafka.support.serializer.JsonDeserializer; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.annotation.Bean; @@ -20,7 +19,7 @@ public class ApplicationConfiguration { @Bean public ExampleConsumer exampleConsumer( - Consumer kafkaConsumer, + Consumer kafkaConsumer, ApplicationProperties properties, ConfigurableApplicationContext applicationContext) { @@ -33,7 +32,7 @@ public class ApplicationConfiguration } @Bean(destroyMethod = "") - public KafkaConsumer kafkaConsumer(ApplicationProperties properties) + public KafkaConsumer kafkaConsumer(ApplicationProperties properties) { Properties props = new Properties(); props.put("bootstrap.servers", properties.getBootstrapServer()); @@ -50,7 +49,7 @@ public class ApplicationConfiguration props.put("metadata.maxage.ms", 5000); // 5 Sekunden props.put("partition.assignment.strategy", StickyAssignor.class.getName()); props.put("key.deserializer", StringDeserializer.class.getName()); - props.put("value.deserializer", JsonDeserializer.class.getName()); + props.put("value.deserializer", StringDeserializer.class.getName()); props.put("spring.json.trusted.packages", "de.juplo.messages"); return new KafkaConsumer<>(props); diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java index b61d8b29..bf6d9cee 100644 --- a/src/main/java/de/juplo/kafka/ExampleConsumer.java +++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java @@ -14,7 +14,7 @@ import java.util.Arrays; @Slf4j -public class ExampleConsumer implements Runnable +public class ExampleConsumer implements Runnable { private final String id; private final String topic; @@ -96,12 +96,12 @@ public class ExampleConsumer implements Runnable { consumed++; log.info("{} - partition={}-{}, offset={}: {}={}", id, topic, partition, offset, key, value); - switch (value.getType()) - { - case ADD -> addNumber((Add)value); - case CALC -> calcSum((Calculate)value); - default -> log.error("{} - Ignoring message of unknown typ {}", id, value.getType()); - } + // switch (value.getType()) + // { + // case ADD -> addNumber((Add)value); + // case CALC -> calcSum((Calculate)value); + // default -> log.error("{} - Ignoring message of unknown typ {}", id, value.getType()); + // } } private void addNumber(Add add) -- 2.20.1