#apache-kafka #kubernetes-helm #bitnami
Вопрос:
Я устанавливаю bitnami/kafka
кластер с помощью helm.
Я хочу, чтобы производители и потребители не входили в кластер k8s, это мой конфигурационный файл yaml для установки руля.
replicaCount: 3
service:
type: LoadBalancer
loadBalancerIP: 192.168.99.110
nodePorts:
client: 25100
external: 25101
externalAccess:
enabled: true
service:
type: LoadBalancer
port: 9094
nodePorts:
- 25100
- 25101
loadBalancerIPs:
- 192.168.99.120
- 192.168.99.121
Я ожидал, что каждый брокер будет рекламировать свой собственный адрес, но они предоставляют внутренний доменный адрес kubernetes, например kf-kafka-1.kf-kafka-headless.default.svc.cluster.local:9092
пожалуйста, помогите мне, что я делаю
Комментарии:
1. Посмотрите в этом разделе, что вам нужно установить
externalAccess.enabled: true
иexternalAccess.service
исходя из ваших потребностей.2. @SaikatChakrabortty спасибо, я думаю, что я уже настроил все свойства для доступа извне. Я хочу настроить своего потребителя следующим
new KafkaConsumer("192.168.99.120:25100,192.168.99.121:25101
образом * я изменил свои свойства
Ответ №1:
Я нажал, чтобы подключить порт на externalAccess.service.nodePorts
но следует использовать только {externalAccess.service.loadBalancerIPs[n]}:9004
Спасибо.