kafaka 消费者组示例
消费群是多线程 或 多机器的Apache Kafka主题.
消费者群体
消费者可以使用相同的"group.id"加入群组
kafka将主题的分区分配给组中的使用者,以便每个分区仅由组中的一个使用者使用
kafka保证消息只能被组中的一个消费者读取
消费者可以按照消息存储在日志中的顺序查看消息
重新平衡消费者
添加更多进程/线程将导致Kafka重新平衡.如果任何消费者或代理无法向Zookeeper发送心跳,则可以通过Kafka集群重新配置.在此重新平衡期间,kafka将分配可用分区到可用线程,可能将分区移动到另一个进程.
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
