在 kafkajs消费者滞后方面需要一些帮助
一个 kubernetes pod 向 queque 发送 10 条消息，kafdrop 中的最后一个偏移量为 10，所有消息都成功传递到 3rd 方系统并成功提交
但是，kafdrop 中存在消费者延迟，有时是 1 条消息，有时是 3条消息，而且是随机的
如果我们向 kafka 发送另外 10 条消息，一切正常 如果我们重新启动消费者 POD，延迟的消息将被发送并提交两次
kafkajs在第 3 方响应后设置为手动提交
请给点建议
在 kafkajs消费者滞后方面需要一些帮助
一个 kubernetes pod 向 queque 发送 10 条消息，kafdrop 中的最后一个偏移量为 10，所有消息都成功传递到 3rd 方系统并成功提交
但是，kafdrop 中存在消费者延迟，有时是 1 条消息，有时是 3条消息，而且是随机的
如果我们向 kafka 发送另外 10 条消息，一切正常 如果我们重新启动消费者 POD，延迟的消息将被发送并提交两次
kafkajs在第 3 方响应后设置为手动提交
请给点建议