用java写的kafka,开始运行消费者后,不杀进程的条件下,有什么办法可以停止消费者呢?

scattered and scattered 发表于: 2020-02-18   最后更新时间: 2020-02-18 18:48:06   2,000 游览

大佬,用java写的kafka,开始运行消费者后,不杀进程的条件下,有什么办法可以停止消费者呢?要求用java根据消费组以及消费主题进行停止?这样可以做到吗?

发表于 2020-02-18
¥1.0
consumer.close();

topic和消费组的信息对应到每个consumer实例,当你要停止某个topic或消费者组的时候,找到对应的实例,调用close()即可。

好的,谢谢大佬

你的答案

查看kafka相关的其他问题或提一个您自己的问题