我正在使用aws-msk-kafka管理的流媒体服务，突然之间我没有通过我的消费者接收到任何消息。我使用的是kafkapython，奇怪的是，当我打开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)