X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FDeadLetterTopicConsumer.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FDeadLetterTopicConsumer.java;h=ac8c65de2011e1491bad0885ecfdf213b4a578e2;hb=62f4cd9765ce308804bdf1ced3fab02d7c7eac2e;hp=a52a6a522e84e0bcfc92a7165720ac16703a9599;hpb=803f73e0c0d6bf65e5887e7bfa5c45d8a5c29abc;p=demos%2Fkafka%2Ftraining

diff --git a/src/test/java/de/juplo/kafka/DeadLetterTopicConsumer.java b/src/test/java/de/juplo/kafka/DeadLetterTopicConsumer.java
index a52a6a5..ac8c65d 100644
--- 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(