如何解决如何在Kafka中为消费者获取最后一次提交的偏移量？
我有一个从 Kafka Topic 读取的 Spring Boot 微服务应用程序。该应用程序从该主题读取并在消耗该主题的所有数据之前中途停止。该应用程序已停止 2 个月，现在当我重新启动该应用程序时，它显示的负载为 0，这是错误的，因为它没有读取所有数据？有没有办法获得消费者最后提交的偏移量？
解决方法
您可以使用 kafka-consumer-groups --bootstrap-server <brokers> --group <id> --describe 来查找已提交的偏移量
如果当前和最新的偏移量匹配，或者延迟为零，则没有消息要读取
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
