我是卡夫卡,動物園管理員和風暴的新手。 我的環境我們有一個卡夫卡經紀人連接到多個動物園管理員。生產者將消息發送到一個經紀人的特定主題和分區到多個動物園管理員與多個經紀人到多個動物園管理員有什麼優勢?一個卡夫卡經紀人連接到多個動物園管理員
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(沒有動物園管理員配置)