python - Kafka 阅读主题——从头开始

Question

我有一个带有 3 个代理和 3 个动物园的 Kafka 集群。使用 1 个分区和 3 个复制因子创建的主题。当我尝试使用 --partition 从主题中读取时 - 没关系。

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic --offset 0 --partition 0 

但是当我尝试从头开始阅读时

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic --from-beginning 

没有任何输出

Kafka version ./kafka-topics.sh --version 2.5.0 (Commit:66563e712b0b9f84)

你能帮我理解也许我错过了一些配置属性，以及我如何阅读--from-beginning？

在我的 Python 代码中也是如此：

from kafka import TopicPartition, KafkaConsumer
consumer = KafkaConsumer(auto_offset_reset='smallest', bootstrap_servers='my_server:9092')
**consumer.assign([TopicPartition('my_topic', 0)])**
msg = next(consumer)
for msg in consumer:
    print (msg)

它仅在我显示分区 0 时才有效

**consumer.assign([TopicPartition('my_topic', 0)])**

标签： pythonpython-3.xapache-kafka