不能 read\write 来自 kafka 主题

Question

我在桌面上的容器中安装了 Kafka 运行。我可以使用名为 "Kafka tool" 的工具很好地连接到它，例如，我可以在其中查看我的主题。

我在读写 to/from Kafka 主题时遇到问题。令我恼火的是它不会给我错误消息，它的行为就像主题上没有任何消息一样，但它确实存在，我可以看到使用该工具，甚至手动添加了两条消息。

该主题存在并且有两条消息（我使用此 UI 手动添加）

问题：向主题发送消息的代码运行良好，但消息没有到达 Kafka 从主题中读取消息的代码不会读取任何内容。它坐在那里，就像没有要阅读的消息一样。另外，我可以使用相同的消费来列出主题（这表明连接成功）

kafka版本是2.4。知道问题可能是什么吗？我试过 "bootstrap_servers=['localhost:9092', 'kafka-server:9092']" 但还是没用

谢谢

Answer 1

KafkaProducer：需要在send

flush

producer.send('testTopic', b'Hello, World!')
producer.flush()

KafkaConsumer：指定bootstrap_servers和auto_offset_reset

consumer = KafkaConsumer('testTopic',
                         bootstrap_servers=['localhost:9092'],
                         auto_offset_reset='earliest')
for message in consumer:
    print(message)

不能 read\write 来自 kafka 主题

cant read\write from kafka topic

python

apache-kafka

docker

kafka-python

kafka-producer-api