问
读取完所有消息后终止Kafka Console Consumer
潮人_徐达妈 发布于 2022-12-04 16:53我知道必须有办法做到这一点,但我无法弄清楚这一点.一旦我从队列中读取了所有消息,我就需要停止kafka消费者.
有人可以提供这方面的任何信息吗？
1 个回答
-
您可以在启动使用者时使用参数传递参数:-consumer-timeout-ms,如果在此期间未读取任何消息,则会抛出异常.例如,如果在最后2秒内没有新消息到达,则停止使用者:kafka.consumer.ConsoleConsumer -consumer-timeout-ms 2000
您可以在此处查看此选项和所有其他输入选项
2022-12-11 02:55 回答
手机用户2602915671
撰写答案
今天，你开发时遇到什么问题呢？
立即提问
京公网安备 11010802041100号