/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/jobs/DbStreamCdcJobAbstract.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/MongoSinkBuilder.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/proerpties/Constants.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/compnents/JdbcDbReaderComponent.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/dynamic/DynamicDbCollectionMongoSinkBuilder.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/compnents/BinlogCheckpointProcessFunction.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/JobContext.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/compnents/JsonBinlogMetaDebeziumDeserializationSchema.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/jobs/DbStreamCdcKafkaJob.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/BinlogCdcValue.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/RedisOutputFormat.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/proerpties/KafkaConfigProperty.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/compnents/WebHttpSinkWriter.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/proerpties/impls/HdfsCheckpointConfigPropertyImpl_removed.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/StartupOptionUtil.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/proerpties/HttpRegionSinkProperty.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/ThreadContext.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/BinlogOffsetValue.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/compnents/dtos/OrgInfoDTO.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/JdbcBinLogCaptureApp.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/jobs/DbStreamCdcHttpSinkJob.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/MongoOutputFormat.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/CdcSourceMeta.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/utils/RecordHeadUtil.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/proerpties/CheckpointConfigPropertyBuilder.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/dynamic/DynamicDbCollectionMongoWriter.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/proerpties/CdcDatabaseSourceProperty.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/dynamic/DynamicDbCollectionMongoSink.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/FlinkConstants.java
/data/jenkins/workspace/event-platform/src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/cdcs/interceptors/CustomProducerInterceptor.java