kafka关于消费组

kafka关于消费组

   小樱     2022年9月6日 20:49     784    

1、一个消费者只能属于一个消费者组

2、消费者组订阅的topic只能被其中的一个消费者消费

3、不同消费者组中的消费者可以消费同一个topic

4、消费者组中的消费者实例个数不能超过分区的数量

假设分区数量设置为1，消费者实例设置为2，这个时候会发现只有1个消费者在消费消息，另一个消费者闲置。


查看消费者组

./kafka-consumer-groups.sh --bootstrap-server 10.255.20.68:9092 --list


查看特定消费组

./kafka-consumer-groups.sh --bootstrap-server 10.255.20.68:9092 --describe --group zjz


删除消费组

./kafka-consumer-groups.sh --bootstrap-server 10.255.20.68:9092 --delete --group zjz

如果还有程序或者命令链接着消费组，如果进行删除的话就会出现如下错误。

需要都断开链接，然后在进行删除。

Error: Deletion of some consumer groups failed:

Group 'zjz' could not be deleted due to: java.util.concurrent.ExecutionException:org.apache.kafka.common.errors.GroupNotEmptyException: The group is not empty.


文章评论

0

其他文章