Annotations

• @KafkaListener
  • Can be used at class as well as method level
• @KafkaHandler
  • Used at method level
  • Used to listen based on the event payload type
  • https://docs.spring.io/spring-kafka/api/org/springframework/kafka/annotation/KafkaHandler.html

@KafkaListener(id = "multi", topics = "myTopic")
static class MultiListenerBean {
 
    @KafkaHandler
    public void listen(String foo) {
        ...
    }
 
    @KafkaHandler
    public void listen(Integer bar) {
        ...
    }
 
    @KafkaHandler(isDefault = true)
    public void listenDefault(Object object) {
        ...
    }
 
}