X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FDeadLetterTopicConsumer.java;h=ac8c65de2011e1491bad0885ecfdf213b4a578e2;hb=66ff7d205e66616de8aaca94503dbbcd7d281f6d;hp=a52a6a522e84e0bcfc92a7165720ac16703a9599;hpb=e54f6036fecc54ea37001dae5f64d88502acfbe1;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(