kafka system.properties 的 bug

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>

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)) {