2016-06-25 14 views

回答

0

不需要在RdKafka中設置太多,它將使用複製配置在代理/每個主題上。如果你連接到三個經紀人中的一個,它將查詢其他人並連接到他們。

(可選)您可以通過將所有代理以逗號分隔(例如, var producer = new Producer("broker1:9092,broker2:9092,broker3:9092")

+0

其實我有三個經紀人,我只想在一臺服務器上發送數據。我希望我的kafka服務器能夠在另外兩臺服務器上覆制這些數據。現在我的.net客戶端創建到所有經紀人的連接併發送數據到每個影響業績的經紀人。 – Nagu

+1

它已經做到了這一點。對於每個分區,只有一個領導者,而你的.net客戶端只會將你產生的每條消息發送給那個領導者。然後,領導根據需要將該消息分發給其他經紀人。 也許你的主題中有多個分區?然後會有多個領導者,每個分區一個,客戶端會向不同的經紀人發送不同的消息。 –