我正在尝试使用以下文档在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集群像在文档中。
暂无答案!
目前还没有任何答案,快来回答吧!