Flink系列:Kafka Consumer Offset 自动提交设置

    技术2022-08-01  80

     

    开启Check Point时

    Checkpoint后,同步offset给kafka。

    未开启Check Point时

    enable.auto.commit: true auto.commit.interval.ms: 1500
    Processed: 0.019, SQL: 9