WARN o.a.flink.streaming.connectors.kafka.internal.Kafka09Fetcher - Committing offsets to Kafka takes longer than the checkpoint interval. Skipping commit of previous offsets because newer complete checkpoint offsets are available. This does not compromise Flink's checkpoint integrity.
 offset不一致,可能有丢失数据,造成kafka提交的,和checkpoints保存的offset不一致,造成上面错误。