我是卡夫卡,动物园管理员和风暴的新手。 我的环境我们有一个卡夫卡经纪人连接到多个动物园管理员。生产者将消息发送到一个经纪人的特定主题和分区到多个动物园管理员与多个经纪人到多个动物园管理员有什么优势?一个卡夫卡经纪人连接到多个动物园管理员
1
A
回答
0
是的。卡夫卡允许您通过添加经纪商进行扩展。当您像一个代理一样使用Kafka集群时,所有分区都驻留在该单个代理上。但是,当你有多个经纪人时,Kafka会分割他们之间的分区。所以,经纪人A
可能会被选为您的主题的分区1
和2
的领导者,而经纪人B
分区的领导者3
。因此,当您向主题发布消息时,客户端将在两个代理的各个分区之间拆分消息。
请注意,我也提到了领导人选举。将代理添加到您的Kafka集群可以为您提供复制。 Kafka使用ZooKeeper为我的例子中提到的每个分区选举一名领导。一旦领导者被选举出来,客户端就在分区之间分割消息,并将每条消息发送给领导以获得适当的分区。根据主题配置,领导者可以同步地将消息复制到备份。所以,在我的例子,如果该主题复制因子是2
那么券商A
将同步复制的分区1
和2
消息促成B
和经纪人B
将同步复制消息分区3
经纪人A
。
所以,这就是说,添加代理可以提供可扩展性和容错性。
相关问题
- 1. 动物园管理员:如何使用高级消费者找到一个卡夫卡经纪人名单
- 2. 多个经纪人卡夫卡0.7
- 3. 无法连接到卡夫卡生产商的远程动物园管理员
- 4. 将卡夫卡与动物园管理员聚类在一起
- 5. 卡夫卡缓存zkVersion不等于在动物园管理员经纪人不恢复
- 6. 卡夫卡3节点集群动物园管理员无法连接
- 7. 卡夫卡 - 动物园管理员 - ACL配置
- 8. 骆驼卡夫卡动物园管理员例外
- 9. 动物园管理员/卡夫卡与Tomcat - 可能吗?
- 10. 卡夫卡动物园管理员安全
- 11. 弗林克,卡夫卡和动物园管理员与URI
- 12. 领导选举动物园管理员和卡夫卡
- 13. 卡夫卡动物园管理员安装问题
- 14. 卡夫卡:多经纪人架构
- 15. 卡夫卡控制器无法连接到经纪人
- 16. 为什么卡夫卡经纪人连接到自己?
- 17. 没有Kerberized卡夫卡经纪人连接到Kerberized Zookeeper
- 18. 问题连接到卡夫卡经纪人
- 19. 卡夫卡启动失败,动物园管理员超时(远程服务器),但机器可以直接连接到动物园管理员
- 20. 卡夫卡经纪人无法Dockerized春云流服务连接到饲养员
- 21. 创建直接在动物园管理员SCRAM凭证/卡夫卡
- 22. 防止卡夫卡经纪人关闭空闲连接
- 23. pykafka无法连接卡夫卡经纪人
- 24. 如何获得卡夫卡经纪人的连接字符串
- 25. 无缝卡夫卡经纪人查找
- 26. 卡夫卡经纪人与主题
- 27. 动物园管理员或卡夫卡连接时出现错误,显示卡祖笛:: VersionNotSupported错误
- 28. 增加卡夫卡话题数量导致动物园管理员失败
- 29. 卡夫卡镜像是否需要不同的动物园管理员合奏?
- 30. 卡夫卡消费者API(没有动物园管理员配置)