如何将 kafka 的消费者服务公开为连续监听器
How to expose Consumer service for kafka as continuous listener
我有一个 java 程序，我在其中为 kafka 主题编写了消费者。！在 while 循环中连续收听 Consumer 的主题。
为了更好的设计和缩放，while 循环不是一个好主意。是否有任何解决方案或示例可以用来生成可以连续使用 Kafka 主题的线程。
抱歉，您的问题不清楚。请分享类似的内容：我有这个，但想要这个。我个人不理解 "expose a listener service"...
这样的概念
虽然如果您正在寻找类似 Spring 的解决方案，请查看有关该问题的特定项目 - Spring for Apache Kafka.
如果我们在这里谈论 Spring Integration，请注意 Spring Kafka 参考手册中的特定章节。
我有一个 java 程序，我在其中为 kafka 主题编写了消费者。！在 while 循环中连续收听 Consumer 的主题。 为了更好的设计和缩放，while 循环不是一个好主意。是否有任何解决方案或示例可以用来生成可以连续使用 Kafka 主题的线程。
抱歉，您的问题不清楚。请分享类似的内容：我有这个，但想要这个。我个人不理解 "expose a listener service"...
这样的概念虽然如果您正在寻找类似 Spring 的解决方案，请查看有关该问题的特定项目 - Spring for Apache Kafka.
如果我们在这里谈论 Spring Integration，请注意 Spring Kafka 参考手册中的特定章节。