Kafka のトピックのすべてのメッセージを読み取ろうとしています。コンフルエントなクラウド サービスを使用しているため、ローカルホストで Kafka を実行しないでください。構成を次のように設定しました'enable.auto.commit': 'True','auto.offset.reset': 'earliest', 'default.topic.config': {'auto.offset.reset': 'smallest'}。ただし、メッセージが表示されないか、プロデューサーから同時にメッセージを送信すると、すべてのオフセットメッセージではなく、そのメッセージのみが表示されます。
Pythonですべてのオフセットメッセージを読むにはどうすればよいですか?