add log

Author: tjchern

plugins/kafkaplugin/src/main/java/org/tron/eventplugin/MessageSenderImpl.java

@@ -100,23 +100,27 @@ private KafkaProducer createProducer(int eventType){
         String defaultConfig = "kafka.conf";
         File configFile = new File(defaultConfig);
         log.error("file path: {}", configFile.getAbsolutePath());
-        log.error("after configFile");
-        if(configFile.exists()) {
-            log.error("in configFile");
-            Config config = ConfigFactory.load(defaultConfig);
-            if (config.hasPath("authorization.user") && config.hasPath("authorization.passwd")) {
-                String user = config.getString("authorization.user");
-                String passwd = config.getString("authorization.passwd");
-                props.put("security.protocol", "SASL_PLAINTEXT");
-                props.put("sasl.mechanism", "SCRAM-SHA-512");
-                props.put("sasl.jaas.config",
-                    "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"" +
-                        user + "\" password=\"" + passwd + "\";");
-
-                log.error("org.apache.kafka.common.security.scram.ScramLoginModule required username=\"" +
+        log.error("before configFile");
+        Config config = null;
+
+        if (configFile.exists()) {
+            config = ConfigFactory.parseFile(configFile);
+        } else if (Thread.currentThread().getContextClassLoader().getResourceAsStream(defaultConfig) != null) {
+            config = ConfigFactory.load(defaultConfig);
+        }
+        if (config != null && config.hasPath("authorization.user") && config.hasPath("authorization.passwd")) {
+            String user = config.getString("authorization.user");
+            String passwd = config.getString("authorization.passwd");
+            props.put("security.protocol", "SASL_PLAINTEXT");
+            props.put("sasl.mechanism", "SCRAM-SHA-512");
+            props.put("sasl.jaas.config",
+                "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"" +
                     user + "\" password=\"" + passwd + "\";");
-            }
+
+            log.error("org.apache.kafka.common.security.scram.ScramLoginModule required username=\"" +
+                user + "\" password=\"" + passwd + "\";");
         }
+
         log.error("after configFile");
         producer = new KafkaProducer<String, String>(props);