1
我有2個卡夫卡經紀人集羣與複製因子的話題2.如果經紀商之一死，我的生產商可以繼續發送新郵件，以這種退化集羣會發生什麼1節點？或者複製因子2需要2個活動節點，並且messaged將被拒絕？當卡夫卡副本的人下來
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中的地位？