大佬,用java写的kafka,开始运行消费者后,不杀进程的条件下,有什么办法可以停止消费者呢?要求用java根据消费组以及消费主题进行停止?这样可以做到吗?
发表于 2020-02-18
大佬,用java写的kafka,开始运行消费者后,不杀进程的条件下,有什么办法可以停止消费者呢?要求用java根据消费组以及消费主题进行停止?这样可以做到吗?
consumer.close();
topic和消费组的信息对应到每个
consumer
实例,当你要停止某个topic或消费者组的时候,找到对应的实例,调用close()
即可。好的,谢谢大佬
你的答案