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

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

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

kafka
发表于 2020-02-18
scattered and scattered
￥1.0
consumer.close();

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

回复
回答于 4年前
半兽人

好的，谢谢大佬

0 0 回复
你的答案

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

找不到想要的答案？提一个您自己的问题。