Собственный диспетчер канала Кафка не может достичь Кафки за пределами кластера Кубернетес - PullRequest
Новая
       15

Собственный диспетчер канала Кафка не может достичь Кафки за пределами кластера Кубернетес

1 голос
/ 07 апреля 2019

Я пытаюсь настроить диспетчер каналов Kafka в Knative, используя эту документацию: https://github.com/knative/eventing/tree/master/contrib/kafka/config

Все прошло отлично, за исключением того, что диспетчер каналов не может найти моего брокера Kafka.Ошибка от модуля kafka-channel-dispatcher-0:

{"level": "fatal", "ts": 1554634078.4035408, "caller": "dispatcher / main.go: 65", "msg":"невозможно создать диспетчер kafka.", "ошибка": "невозможно создать клиент kafka: kafka: на клиенте закончились доступные брокеры для общения (доступен ли ваш кластер?)", "stacktrace": "main.main \п \ т / дома / Михель / перейти / SRC / github.com / knative / троеборье / вно / Kafka / CMD / диспетчер / main.go: 65 \ nruntime.main \ п \ т / USR / Lib / его-1.10 /src / runtime / proc.go: 198 "}

У меня есть один узел Kafka, работающий на другом компьютере, чем кластер K8s, но они находятся в одной сети.Я попытался связаться с брокером Kafka без использования Knative, запустив контейнер с некоторым Python, и это было успешно, поэтому я знаю, что брокер доступен.

Вот карта конфигурации диспетчера каналов Kafka: 

apiVersion: v1
kind: ConfigMap
metadata:
  name: kafka-channel-controller-config
  namespace: knative-eventing
data:
  # Broker URL's for the provisioner. Replace this with the URL's for your kafka cluster.
  bootstrap_servers: 10.142.15.232:9092

  # Consumer mode to dispatch events from different partitions in parallel.
  # By default(multiplex), partitions are multiplexed with a single go channel.
  # `multiplex` and `partitions` are valid values.
  ## consumer_mode: partitions

Что я могу сделать, чтобы связаться с моим брокером?Может быть, это как-то связано с тем, что я предоставляю IP-адрес вместо URL, как в примере с документом: 

# Broker URL's for the provisioner
bootstrap_servers: my-cluster-kafka-bootstrap.my-kafka-namespace:9092

Обновление: Я могу связатьсякластер стримзи кафка как в документации.

...