job.name=cdc to kafka checkpoint.mode=file checkpoint.disk.location=E:/bcxin/flink/binlog2Kafka_kms_team checkpoint.hdfs.config=core-site-default.xml kafka.bootstrap.server=43.155.113.170:9092 kafka.cdc.topic.prefix=[dbName].cdc.topic.new.key.[tableName] kafka.consumer.group.id=cdc-binlog-flink-consumer-kms_team