我們具體說說***的概念,從構成上來說,它是若干個逗號分隔的三元組,每個三元組的格式為《協議名稱,主機名,埠號》。這裡的協議名稱可能是標準的名字,比如 plaintext 表示明文傳輸、ssl 表示使用 ssl 或 tls 加密傳輸等;也可能是你自己定義的協議名字,比如controller: //localhost:9092。
一旦你自己定義了協議名稱,你必須還要指定listener.security.protocol.map引數告訴這個協議底層使用了哪種安全協議,比如指定listener.security.protocol.map=controller:plaintext表示controller這個自定義協議底層使用明文不加密傳輸資料。
至於三元組中的主機名和埠號則比較直觀,不需要做過多解釋。不過有個事情你還是要注意一下,經常有人會問主機名這個設定中我到底使用 ip 位址還是主機名。這裡我給出統一的建議:最好全部使用主機名,即 broker 端和 client 端應用配置中全部填寫主機名。 broker 源**中也使用的是主機名,如果你在某些地方使用了 ip 位址進行連線,可能會發生無法連線的問題。
Kafka集群配置
1 kafka概念 topic kafka 按照topic 分類來維護訊息,每個topic可以配置多個partition 分割槽 每個分割槽只能被乙個消費者消費,每個partition對應乙個commit log檔案 producer 我們將發布 publish 訊息到topic的程序稱之為生產者 ...
Kafka 幾個重要的配置總結
注意 配置基於kafka 0.8.2.1 broker配置 非負整數,用於唯一標識broker broker.id 0 kafka持久化資料儲存的路徑,可以指定多個,以逗號分隔 log.dirs tmp kafka logs broker接收連線請求的埠 port 9092 指定zk連線字串,hos...
Kafka詳解二 如何配置Kafka集群
kafka集群配置比較簡單,為了更好的讓大家理解,在這裡要分別介紹下面三種配置 1.首先啟動zookeeper服務 kafka本身提供了啟動zookeeper的指令碼 在kafka bin 目錄下 和zookeeper配置檔案 在kafka config 目錄下 首先進入kafka的主目錄 可通過 ...