From 9b7d62717ea210d933347a712e38a08c02a04ddd Mon Sep 17 00:00:00 2001
From: machengyuan4081 <ma198412>
Date: Mon, 11 Jun 2018 23:31:02 +0800
Subject: [PATCH] =?UTF-8?q?kafka=20system.properties=20=E7=9A=84=20bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 kafka/pom.xml                                                   | 2 ++
 .../alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java   | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

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 @@
                         <exclude>**/canal.properties</exclude>
                         <exclude>**/spring/**</exclude>
                         <exclude>**/example/**</exclude>
+                        <exclude>**/example2/**</exclude>
+                        <exclude>**/kafka.yml</exclude>
                     </excludes>
                 </configuration>
             </plugin>
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)) {