尝试使用CentOS上的Python客户端在本地连接到Kafka 0.10.0.0时出现了一个非常奇怪的问题。尝试连接到Kafka时没有Brokers可用错误
我的连接选项非常简单,默认:
kafka_consumer = kafka.KafkaConsumer(
bootstrap_servers=['localhost:9092'],
client_id="python-test-consumer"
)
当我手动设置听众选项,在卡夫卡的server.properties文件,如:
listeners=PLAINTEXT://localhost:9092
我得到的kafka.errors。 NoBrokers可用,尽管我仍然可以使用curl或其他linux工具轻松连接到Kafka broker服务器。
否advertised.listeners或其他不赞成广告的选项有助于解决问题。因此,正在工作的唯一配置状态是没有监听者的状态。那肯定是不可接受的,因为我们需要以某种方式设置本地集群。
看来,这个愚蠢的问题的解决方案很简单,并且在想,但我们无法自己想象它。
检出这个主题: http://stackoverflow.com/questions/35689238/kafka-python-producer-is-not-able-to-connect/40282989#40282989 –