2017-04-11 35 views

回答

0

我認爲你的意思是要問如何維護Kafka經紀人之間的副本,這些經紀人一起被認爲是Kafka集羣。

如果是這樣的話,這是很簡單的,你所要做的就是配置一個卡夫卡集羣,並創造與大小複製因子等於在羣集節點的大小的話題。

例如:

比方說,我們要對我們的卡夫卡集羣3個經紀商,那麼你就需要爲每個經紀人準備不同的配置文件,然後啓動它們作爲一個集羣,並然後創建的3

複製因子的話題卡夫卡將負責維護容錯。

有關居然配置,在YouTube上觀看這些視頻進一步信息:

https://www.youtube.com/channel/UCDLPjuuYHxPbHdN8RXxrGdw

+1

對不起ü誤會是錯誤的。順便說一句,情況並非如此。我有跨多個節點的單個羣集,目前我在每個節點上運行一個代理實例。我有一個5的複製因子,它是完全正確的。假設如果整個集羣都關閉了,我不想鬆散數據/生產者,消費者等待。因此,我打算複製到另一個DC。最終,我想增加生產者和消費者的可用性。希望你明白這個問題。 –

相關問題