如何将 kafka 的消费者服务公开为连续监听器答案

【问题标题】：How to expose Consumer service for kafka as continuous listener如何将 kafka 的消费者服务公开为连续监听器
【发布时间】：2017-01-31 10:53:38
【问题描述】：

我有一个 java 程序，我在其中为 kafka 主题编写了消费者。！在while循环中不断地听消费者的话题。为了更好的设计和缩放，while 循环不是一个好主意。是否有任何解决方案或示例可以用来生成可以连续使用 Kafka 主题的线程。

【问题讨论】：

【解决方案1】：

抱歉，您的问题不清楚。请分享类似的内容：我有这个，但想要这个。而且我个人不理解“公开侦听器服务”之类的概念...

虽然如果您正在寻找类似 Spring 解决方案的东西，请查看有关此问题的特定项目 - Spring for Apache Kafka。

如果我们在这里谈论Spring Integration，请注意 Spring Kafka 参考手册中的特定章节。

【讨论】：

我已尝试根据您的输入改进问题，如果您建议我会尝试再次即兴发挥，因为我对卡夫卡空间有点陌生。
太棒了！正如我回答你的那样：阅读 Spring Kafka 手册和那个库。 KafkaListenerContainer 为你做这些事情。它实际上是在其特殊线程中的 while 循环中轮询 Kafka 主题。