我正在努力阅读Kafka主题的所有信息。我正在使用合流云服务，所以不要在我的localhost中运行kafka。我将配置设置为： 'enable.auto.commit': 'True','auto.offset.reset': 'earliest', 'default.topic.config': {'auto.offset.reset': 'smallest'} . 然而，它没有给我消息，或者如果我从生产者发送消息，在同一时间，它只给出该消息，而不是所有的偏移消息。
如何读取python中的所有偏移量消息？
1条答案
按热度按时间xdyibdwo1#
我没有使用合流云服务，如果你想消耗所有的补偿，有几件事你应该注意。
设置不使用任何数据的新使用者groupid
设置“auto.offset.rese=earliest”或“auto.offset.reset=smallest”，您需要参考Kafka版本
注意主题的自动过期日期