У меня есть кластер kubernetes, размещенный в облаке azure. Я установил ресурсы кафки, используя приведенную ниже таблицу управления https://github.com/confluentinc/cp-helm-charts/tree/master/charts/cp-kafka. На этой карте рулевого управления успешно развернуты модули zoopkeeper и брокеры et c. Теперь я хочу написать приложение на основе golang, которое подключается к любому из брокеров kafka, установленных в моем кластере kubernetes, создает нового производителя и публикует сообщения. Любая помощь будет принята с благодарностью.
Вы должны развернуть свой код Golang в контейнере в k8s, а затем установить bootstrap.servers на имя службы развертывания Kafka, в идеале через переменную среды
bootstrap.servers