Greedyu opened a new pull request, #4113: URL: https://github.com/apache/incubator-inlong/pull/4113
[INLONG-4112][Agent] mysql binlog supports collection from a specified start #4112 ### Motivation 1. mysql binlog supports collection from a specified start 2. Fix BinlogReader init() bug ### Modifications Refer to flink to specify the location reading method。The core principle is to modify the OffsetBackingStore object when initializing the OffsetStorageWriter class in the configure() of the FlinkOffsetBackingStore class. When specifying the location, the "offset.storage" configuration here directly uses FlinkOffsetBackingStore.class.getCanonicalName(), and specifies FlinkOffsetBackingStore.OFFSET_STATE_VALUE, "snapshot.mode" and other parameters according to the flink configuration ### Verifying this change  -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
