我的项目将 Apache Kafka 视为老化的基于 JMS 的消息传递方法的潜在替代品。为了让这个过渡尽可能的顺利，如果替换队列系统(Kafka)有一个异步订阅机制就更理想了，类似于我们当前项目的JMS机制使用MessageListener。和 MessageConsumer订阅主题并接收异步通知。我不太关心 Kafka 是否严格遵守 JMS API，但相反，如果不需要，我宁愿不重新设计我们的整个发布-订阅-通知类套件。
我可以找到各种KafkaConsumer polling examples , 但到目前为止还没有找到任何通过异步通知向客户端通知新消息的示例。
有谁知道当前版本的 Kafka(截至本文发布时为 0.10.2)是否提供了这样的 API，或者我是否一直在尝试使用轮询重写遗留代码？
最佳答案
Kafka 客户端仅提供按需池机制，但您可以使用 spring-kafka .它提供了MessageListener接口(interface)和KafkaListener注解等。参见 documentation .
关于java - Apache Kafka 是否提供异步订阅回调 API？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/43546252/