knative kafka信道调度器无法到达kubernetes集群外的kafka

uhry853o  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(213)

我正在尝试使用以下文档在knative中设置kafka通道调度器:https://github.com/knative/eventing/tree/master/contrib/kafka/config
一切都很顺利,只是频道调度员找不到我的Kafka经纪人。pod出错 kafka-channel-dispatcher-0 :
{“level”:“fatal”,“ts”:1554634078.4035408,“caller”:“dispatcher/main.go:65”,“msg”:“unable to create kafka dispatcher.”,“error”:“unable to create kafka client:kafka:client has run out of available brokers to talk to(your cluster reable?),“stacktrace”:“main.main\n\t/home/michiel/go/src/github.com/knative/eventing/contrib/kafka/cmd/dispatcher/main.go:65\nruntime.main\n\t/usr/lib/go-1.10/src/runtime/proc.go:198”}
我有一个kafka节点运行在与k8s集群不同的机器上,但它们在同一个网络中。我尝试在不使用knative的情况下通过运行带有python的容器来访问kafka代理,这是成功的,因此我知道代理是可以访问的。
以下是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

更新:我可以找到一个斯特里姆齐Kafka集群像在文档中。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题