卡夫卡消費者如何選擇消費最近的經紀商？

Question

我在三臺主機上部署了一個kafka集羣，並將消費者部署在同一臺主機上。 我如何讓消費者消費最近的經紀人的分區。例如，host a的消費者只消費屬於host a的分區。

Answer 1

卡夫卡不會這樣工作。客戶將連接到所有三家經紀商，並根據哪些節點當前是每個主題分區的領導者並行生產並消費所有三家經紀商。