apache-kafka - 可以使用cli接收消息，但不能从kafka python获取消息

Question

我正在使用 AWS MSK Kafka 托管流服务，突然之间我没有通过我的消费者收到任何消息。我正在使用 kafka-python，奇怪的是，当我打开我的 cli 并使用完全相同的代码创建一个新的使用者时，我收到的消息就好了。如果我重新启动 kafka 代理，只有这样我才能收到消息。知道问题可能是什么吗？

>>> consumer = KafkaConsumer(
...                 bootstrap_servers=[...],
...                 auto_offset_reset='earliest',
...                 enable_auto_commit=True,
...                 group_id='my-client-id',
...                 api_version=(2, 2, 1))
>>> consumer.subscribe(['hello_world', 'foo_bar'])
>>> for message in consumer:
...     print(message)

标签： apache-kafkakafka-python