From 5dc320da833d4c60d2798f447ceb00f1b566d357 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 20 Mar 2026 18:13:34 +0100 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 a45c1505..3e2dbbcb 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 0c06b10f..358a7bb6 100644 --- a/src/main/java/de/juplo/kafka/DeadLetterConsumer.java +++ b/src/main/java/de/juplo/kafka/DeadLetterConsumer.java @@ -12,7 +12,7 @@ import java.util.Arrays; @Slf4j -public class ExampleConsumer implements Runnable, SmartLifecycle +public class DeadLetterConsumer implements Runnable, SmartLifecycle { private final String id; private final String topic; @@ -23,7 +23,7 @@ public class ExampleConsumer implements Runnable, SmartLifecycle private long consumed = 0; - public ExampleConsumer( + public DeadLetterConsumer( String clientId, String topic, Consumer consumer) -- 2.39.5