java - 如何使用 POJO 处理来自 kafka lister 的事件？

Question

我正在尝试使用注释@KafkaListener并监听我自己的事件:

  public class Listener {
        @KafkaListener(id = "SimpleListener", topics = "mytopic")
        public void receive(SimpleEvent event) {
             ...
        }
    }

  @Component     
  public class MyEventHandler {
      @EventListener
      public void eventHandler(SimpleEvent event) {
           ...
      }
   }

这样可以吗？我想在服务组件中监听事件并处理每个不同的事件。

Answer 1

正确。这可以通过将 MessageConverter 注入(inject)到 ContainerFactory 中实现:https://docs.spring.io/spring-kafka/docs/2.1.0.RELEASE/reference/html/_reference.html#serdes