gpt4 book ai didi

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

转载 作者:行者123 更新时间:2023-12-02 11:47:47 24 4
gpt4 key购买 nike

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

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

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

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

最佳答案

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

关于java - 如何使用 POJO 处理来自 kafka lister 的事件?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48081751/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com