Test repariert: Explizite Consumer-Konfiguration für DLT-Consumer

[demos/kafka/training] / src / test / java / de / juplo / kafka / DeadLetterTopicConsumer.java

diff --git a/src/test/java/de/juplo/kafka/DeadLetterTopicConsumer.java b/src/test/java/de/juplo/kafka/DeadLetterTopicConsumer.java
index a52a6a5..ac8c65d 100644 (file)
--- a/src/test/java/de/juplo/kafka/DeadLetterTopicConsumer.java
+++ b/src/test/java/de/juplo/kafka/DeadLetterTopicConsumer.java
@@ -16,7 +16,10 @@ public class DeadLetterTopicConsumer
   List<Message<?>> messages = new LinkedList<>();
 
 
-  @KafkaListener(id = "DLT", topics = "${sumup.adder.topic}.DLT")
+  @KafkaListener(
+      id = "DLT",
+      topics = "${sumup.adder.topic}.DLT",
+      containerFactory = "dltContainerFactory")
   public void receive(Message<?> message)
   {
     log.info(