无法使用数据

chy5wohz  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(314)

我用bitnami/kafka docker模板创建了一个kafka设置。在多次重新创建容器(我无法连接到9092上的kafka)之后,我终于启动并运行了集群。我相信问题是由docker安装在windows而不是linux上的事实造成的。
我目前的问题是,我无法使用kafka python库和以下代码来使用任何消息:

from kafka import KafkaConsumer
from kafka import TopicPartition

print('Making connection.')
consumer = KafkaConsumer(bootstrap_servers='localhost:9092')

print('Assigning Topic.')
consumer.assign([TopicPartition('linuxhint', 2)])

print('Getting message.')
for message in consumer:
    print("OFFSET: " + str(message[0])+ "\t MSG: " + str(message))

代码没有失败。它打印“获取消息”行,但没有完成。我试着用conduktor应用程序消费同一个主题,但我也做不到。conduktor甚至无法阅读主题的数量和大小。如何排除故障?老实说,我一点也不知道。

x8goxv8g

x8goxv8g1#

windows和docker都是问题所在。这是缺乏完整的Kafka配置。
您需要配置 KAFKA_CFG_ADVERTISED_LISTENERS 并在docker命令中显示正确的端口。
https://github.com/bitnami/bitnami-docker-kafka#accessing-Kafka与内部和外部客户

相关问题