问题描述
我有一个从 Kafka Topic 读取的 Spring Boot 微服务应用程序。该应用程序从该主题读取并在消耗该主题的所有数据之前中途停止。该应用程序已停止 2 个月，现在当我重新启动该应用程序时，它显示的负载为 0，这是错误的，因为它没有读取所有数据？有没有办法获得消费者最后提交的偏移量？
解决方法
您可以使用 kafka-consumer-groups --bootstrap-server <brokers> --group <id> --describe 来查找已提交的偏移量
如果当前和最新的偏移量匹配，或者延迟为零，则没有消息要读取
