问题描述
我正在尝试阅读有关Kafka主题的所有消息。我正在使用融合的云服务，所以不要在本地主机中运行Kafka。我将配置设置为：'enable.auto.commit': 'True','auto.offset.reset': 'earliest','default.topic.config': {'auto.offset.reset': 'smallest'}。但是，它没有给我任何消息，或者如果我同时从生产者发送消息，则它仅给出该消息，而不是所有偏移消息。
如何读取python中的所有偏移量消息？
解决方法
我没有使用融合的云服务，如果要消耗所有偏移量，则需要注意一些事项。
- 设置不消耗任何数据的新消费者groupId
- 设置“ auto.offset.rese =最早”或“ auto.offset.reset =最小”，您需要参考kafka版本
- 请注意该主题的自动失效日期