在我们的Openshift生态系统中,我们有一个来自wurstmeister/kafka
的kafka实例。到目前为止,我可以使用以下参数使用Openshift
系统访问卡夫卡,
KAFKA_LISTENERS=PLAINTEXT://:9092
KAFKA_ADVERTISED_HOST_NAME=kafka_service_name
当然,港口和动物园的副翼也在那里。
我能够从openshift系统中的吊舱中访问kafka。但我无法从主机上获得卡夫卡服务。即使我可以用它的IP访问卡夫卡吊舱,也可以用telnet Pod_IP 9092
来进行拨号。
当我试图使用卡夫卡制作者从主机连接时,我得到了以下错误,
2017-08- 07 :45:13,925]获取相关id 2:{tls21=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)的元数据时警告错误
当我尝试用IP从主机上连接卡夫卡消费者时,它是空白的。
注意:到目前为止,是一个单独的openshift服务器。用例用于开发测试。
发布于 2017-08-07 12:35:40
也许你想看看这个让卡夫卡在OpenShift?https://github.com/EnMasseProject/barnabas上的POC
https://stackoverflow.com/questions/45546197
复制相似问题