我用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甚至无法阅读主题的数量和大小。如何排除故障?老实说,我一点也不知道。
1条答案
按热度按时间x8goxv8g1#
windows和docker都是问题所在。这是缺乏完整的Kafka配置。
您需要配置
KAFKA_CFG_ADVERTISED_LISTENERS
并在docker命令中显示正确的端口。https://github.com/bitnami/bitnami-docker-kafka#accessing-Kafka与内部和外部客户