Panda

好的 感谢 我试下

手动调整 offset

可以尝试手动调整 offset，定位成最新的：

kafka-consumer-groups.sh --bootstrap-server <KAFKA_BROKER> --group TO_WMS --reset-offsets --to-latest --execute

或将偏移量重置为最早：

kafka-consumer-groups.sh --bootstrap-server <KAFKA_BROKER> --group TO_WMS --reset-offsets --to-earliest --execute

然后重启消费者进程，让其从最新或最早的 offset 重新开始消费。

会的，有需求，就会排期加上。

了解,后续可以支持上安全策略么

我刚才漏了一条，你刷新下。