无法从kafka主题读取/写入

mepcadol 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(428)

这个问题在这里已经有答案了：

连接Kafka在docker中跑步（3个答案）
9个月前关门了。
我的桌面上有一个容器在运行Kafka。我可以使用一个叫做“Kafka工具”的工具连接到它，在这里我可以看到我的主题。
我对Kafka主题的阅读和写作有问题。让我恼火的是，它不会给我一个错误消息，它的行为就像如果主题上没有任何消息，但它有，我可以看到使用该工具，甚至手动添加了两条消息。
该主题存在并且有两条消息（我使用这个ui手动添加了这两条消息）
问题：将消息发送到主题的代码运行良好，但这些消息不会发送到kafka从主题读取消息的代码不会读取任何内容。它坐在那里，好像没有信息可读。另外，我可以使用相同的consume来列出主题（这表示连接成功）
Kafka的版本是2.4。你知道问题出在哪里吗？我试过“bootstrap\u servers=['localhost:9092'，'Kafka-server:9092“]”但它也不起作用
谢谢

python apache-kafka docker kafka-producer-api kafka-python

来源：https://stackoverflow.com/questions/60791807/cant-read-write-from-kafka-topic

1条答案

按热度按时间

vohkndzv1#

Kafka：你需要执行 flush 之后 send ```
producer.send('testTopic', b'Hello, World!')
producer.flush()

Kafka消费者：指定 `bootstrap_servers` 以及 `auto_offset_reset` ```
consumer = KafkaConsumer('testTopic',
                         bootstrap_servers=['localhost:9092'],
                         auto_offset_reset='earliest')
for message in consumer:
    print(message)

赞(0）回复(0）举报 2021-06-05

我来回答

无法从kafka主题读取/写入

1条答案

相关问题

热门标签

最新问答