kafaka 消费者组示例
消费群是多线程 或 多机器的Apache Kafka主题.
消费者群体
消费者可以使用相同的"group.id"加入群组
一个组的最大并行度是组中的消费者数量<--不是分区
kafka将主题的分区分配给组中的使用者,以便每个分区仅由组中的一个使用者使用
kafka保证消息只能被组中的一个消费者读取
消费者可以按照消息存储在日志中的顺序查看消息
重新平衡消费者
添加更多进程/线程将导致Kafka重新平衡.如果任何消费者或代理无法向Zookeeper发送心跳,则可以通过Kafka集群重新配置.在此重新平衡期间,kafka将分配可用分区到可用线程,可能将分区移动到另一个进程.