kafaka 消費者組示例
消費群是多線程 或 多機器的Apache Kafka主題.
消費者群體
消費者可以使用相同的"group.id"加入群組
一個組的最大並行度是組中的消費者數量<--不是分區
kafka將主題的分區分配給組中的使用者,以便每個分區僅由組中的一個使用者使用
kafka保證消息只能被組中的一個消費者讀取
消費者可以按照消息存儲在日志中的順序查看消息
重新平衡消費者
添加更多進程/線程將導致Kafka重新平衡.如果任何消費者或代理無法向Zookeeper發送心跳,則可以通過Kafka集群重新配置.在此重新平衡期間,kafka將分配可用分區到可用線程,可能將分區移動到另一個進程.