1 package de.juplo.kafka;
4 import lombok.extern.slf4j.Slf4j;
5 import org.springframework.kafka.annotation.KafkaHandler;
6 import org.springframework.kafka.annotation.KafkaListener;
7 import org.springframework.stereotype.Component;
9 import java.util.LinkedList;
10 import java.util.List;
14 @KafkaListener(topics = "test")
17 public class MultiMessageConsumer
19 private final List<Foo> foos = new LinkedList<>();
20 private final List<Bar> bars = new LinkedList<>();
24 public void handleFoo(Foo foo)
26 log.info("Received a Foo: {}", foo);
31 public void handleBar(Bar bar)
33 log.info("Received a Bar: {}", bar);