如何解决在Python中读取所有偏移量kafka
我正在尝试阅读有关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版本
- 请注意该主题的自动失效日期
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
