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(