在我们的openshift生态系统中,我们有一个来自 wurstmeister/kafka
. 到现在为止,我已经可以使用 Openshift
系统使用以下参数,
KAFKA_LISTENERS=PLAINTEXT://:9092
KAFKA_ADVERTISED_HOST_NAME=kafka_service_name
当然,port和zookeper的参数也在那里。
我可以从openshift系统中的pods访问Kafka。但我无法从主机访问kafka服务。即使我能用ip访问Kafka吊舱,也能用, telnet Pod_IP 9092
当我试图使用Kafka生产者从主机连接,我得到以下错误,
2017-08-07 07:45:13925]获取相关id为2的元数据时出现警告错误:{tls21=leader\u not\u available}(org.apache.kafka.clients.networkclient)
当我尝试从kafka消费者使用ip从主机连接时,它是空白的。
注意:到目前为止,它是一个openshift服务器。用例用于开发测试。
1条答案
按热度按时间slhcrj9b1#
也许你想看看这个让Kafka上openshift的poc?https://github.com/enmasseproject/barnabas