如何使用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注入ContainerFactory：https://docs.spring.io/spring-kafka/docs/2.1.0.RELEASE/reference/html/_reference.html#serdes