From 5faa5a76207cec831f5c91a148ef9e48defe18da Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 6 Apr 2025 12:03:56 +0200 Subject: [PATCH] `ExampleConsumer` in `DeadLetterConsumer` umbenannt -- ALIGN --- src/main/java/de/juplo/kafka/ApplicationConfiguration.java | 4 ++-- src/main/java/de/juplo/kafka/DeadLetterConsumer.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index ea6b64e..5730a45 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -16,13 +16,13 @@ import java.util.Properties; public class ApplicationConfiguration { @Bean - public ExampleConsumer exampleConsumer( + public DeadLetterConsumer exampleConsumer( Consumer kafkaConsumer, ApplicationProperties properties, ConfigurableApplicationContext applicationContext) { return - new ExampleConsumer( + new DeadLetterConsumer( properties.getClientId(), properties.getConsumerProperties().getTopic(), kafkaConsumer, diff --git a/src/main/java/de/juplo/kafka/DeadLetterConsumer.java b/src/main/java/de/juplo/kafka/DeadLetterConsumer.java index 1f5a570..21a0e9c 100644 --- a/src/main/java/de/juplo/kafka/DeadLetterConsumer.java +++ b/src/main/java/de/juplo/kafka/DeadLetterConsumer.java @@ -11,7 +11,7 @@ import java.util.Arrays; @Slf4j -public class ExampleConsumer implements Runnable +public class DeadLetterConsumer implements Runnable { private final String id; private final String topic; @@ -22,7 +22,7 @@ public class ExampleConsumer implements Runnable private long consumed = 0; - public ExampleConsumer( + public DeadLetterConsumer( String clientId, String topic, Consumer consumer, -- 2.20.1