diff --git a/kafka/pom.xml b/kafka/pom.xml index 5c015e56..4cb0b9bf 100644 --- a/kafka/pom.xml +++ b/kafka/pom.xml @@ -57,6 +57,8 @@ **/canal.properties **/spring/** **/example/** + **/example2/** + **/kafka.yml diff --git a/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java b/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java index a0dc3691..e89daefc 100644 --- a/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java +++ b/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java @@ -35,7 +35,7 @@ public class CanalKafkaStarter { try { logger.info("## load kafka configurations"); - String conf = System.getProperty("canal.conf", "classpath:kafka.yml"); + String conf = System.getProperty("kafka.conf", "classpath:kafka.yml"); KafkaProperties kafkaProperties; if (conf.startsWith(CLASSPATH_URL_PREFIX)) {