首頁猿問如何連接到使用 confluent...

如何連接到使用 confluent helm chart 安裝的 kafka

Go

ibeautiful 2022-05-18 14:26:31

我有一個托管在天藍色云上的 Kubernetes 集群。我已經使用下面的 helm 圖表https://github.com/confluentinc/cp-helm-charts/tree/master/charts/cp-kafka安裝了 kafka 資源。這個 helm chart 成功部署了 zoopkeeper pod 和 broker pod 等?，F(xiàn)在我想編寫一個基于 golang 的應用程序，它與安裝在我的 kubernetes 集群上的任何 kafka 代理連接，并創(chuàng)建一個新的生產者并發(fā)布消息。任何幫助將不勝感激。

查看完整描述

2 回答

PIPIONE

TA貢獻1829條經驗獲得超9個贊

您可以在 bootstrap.servers 中使用以下字符串與<helm-release-name>-cp-kafka-headless.<namespace>:9092作為 confluent helm chart 的一部分創(chuàng)建的代理或引導服務進行通信<helm-release-name>-cp-kafka。當你點擊這個服務時，它會第一次隨機到達任何一個brokers，并獲取所有通過zookeeper同步的元數(shù)據(jù)信息。

隨后的請求將根據(jù)元數(shù)據(jù)中的信息向各個代理發(fā)出。

反對回復 2022-05-18