发现lag不会同步要隔很长一段时间或者量到一定才会同步。发现是没有途中那个同步偏移量的操作，然后消费的时候没有，session不知道groupid。
加入这一行重新启动拉取最新的偏移量，但是其实业务里面已经消费过了。所以功能上是没有问题的。
问题：
为什么没有同步偏移量，消息消费的时候没有一直重复拉取旧的消息重复消费。
发现lag不会同步要隔很长一段时间或者量到一定才会同步。发现是没有途中那个同步偏移量的操作，然后消费的时候没有，session不知道groupid。
加入这一行重新启动拉取最新的偏移量，但是其实业务里面已经消费过了。所以功能上是没有问题的。
问题：
为什么没有同步偏移量，消息消费的时候没有一直重复拉取旧的消息重复消费。
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
