projects
/
demos
/
kafka
/
training
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Service ergänzt, der das Dead-Letter-Topic ausliest
[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<>();
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(
public void receive(Message<?> message)
{
log.info(