我有2个卡夫卡经纪人集群与复制因子的话题2.如果经纪商之一死,我的生产商可以继续发送新邮件,以这种退化集群会发生什么1节点?或者复制因子2需要2个活动节点,并且messaged将被拒绝?当卡夫卡副本的人下来
1
A
回答
3
消息不会被忽略,如果没有。活着的经纪人小于配置的副本。每当新的Kafka代理加入集群时,数据就会被复制到该节点。
可以通过配置的复制因子为3个或更多重现这种情况下,开始只有一个经纪人。
0
一旦新的节点加入到卡夫卡集群,数据将被复制,副本因素不会影响发行人的消息
4
这取决于几个因素:
- 什么是你的制片人配置为acks?如果您配置为“all”,则在ISR列表中的所有节点已将消息复制到所有节点之前,领导代理将不会使用ACK进行应答。此时由生产者决定是否关心ACK。
- min.insync.replicas的价值是多少?如果节点的数量低于此配置,则在有更多节点可用之前,您的经纪商领导者不会接受来自生产者的更多消息。
所以基本上你的制作者可能会暂停一段时间,直到更多的节点结束。
0
复制因子2不需要2个现场经纪人,其发布的消息,而一个经纪人是向下取决于这些配置 - 上面@Javier提到min.insync.replicas
检查那些配置 - 的ACK
相关问题
- 1. 卡夫卡:如何从副本集
- 2. 的ConnectException当集群中的一个卡夫卡券商下来
- 3. 卡夫卡领导人选举造成卡夫卡流崩溃
- 4. 卡夫卡0.10.2消费者获得大量副本
- 5. 春季卡夫卡表现vs本地卡夫卡api
- 6. 卡夫卡与码头工人
- 7. 卡夫卡:多经纪人架构
- 8. 无缝卡夫卡经纪人查找
- 9. 卡夫卡经纪人与主题
- 10. 卡夫卡制片人时间戳
- 11. 卡夫卡制作人消息流
- 12. 水槽VS卡夫卡VS别人
- 13. 多个经纪人卡夫卡0.7
- 14. UnknownCodecException卡夫卡
- 15. 卡夫卡
- 16. 卡夫卡的retention.ms没有被卡夫卡0.10.2强制执行?
- 17. 卡夫卡0.9:消费从最早的卡夫卡偏移
- 18. 卡夫卡与斯卡拉
- 19. 卡夫卡Kubernetes/Minikube
- 20. 卡夫卡,新的存储
- 21. 卡夫卡的Scaladoc(和Javadoc)
- 22. 卡夫卡的Zoopekeeper实例
- 23. 卡夫卡:如何在卡夫卡实现循环分区
- 24. 卡夫卡连接或卡夫卡客户
- 25. 卡夫卡流和卡夫卡表一对多关系加入
- 26. 阿帕奇顶点 - 卡夫卡0.9安全卡夫卡主题
- 27. 如何从卡夫卡用卡夫卡流通过间隔
- 28. 我应该使用什么:卡夫卡流或卡夫卡消费者API或卡夫卡连接
- 29. 卡夫卡制作人'request.timeout.ms'的含义让我很困惑
- 30. 如何知道卡夫卡经纪人在Java中的地位?