fix bug in sasl.jaas.config

tjchern · tjchern · commit 5559a9c817b1 · 2019-07-06T16:42:22.000+08:00
diff --git a/plugins/kafkaplugin/src/main/java/org/tron/eventplugin/MessageSenderImpl.java b/plugins/kafkaplugin/src/main/java/org/tron/eventplugin/MessageSenderImpl.java
@@ -108,7 +108,7 @@ private KafkaProducer createProducer(int eventType){
                 props.put("sasl.mechanism", "SCRAM-SHA-512");
                 props.put("sasl.jaas.config",
                     "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"" +
-                        user + "\" password=\"" + passwd + "\"");
+                        user + "\" password=\"" + passwd + "\";");
             }
         }
         producer = new KafkaProducer<String, String>(props);

Original file line number	Diff line number	Diff line change
`@@ -108,7 +108,7 @@ private KafkaProducer createProducer(int eventType){`
`108`	`108`	`props.put("sasl.mechanism", "SCRAM-SHA-512");`
`109`	`109`	`props.put("sasl.jaas.config",`
`110`	`110`	`"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"" +`
`111`		`- user + "\" password=\"" + passwd + "\"");`
	`111`	`+ user + "\" password=\"" + passwd + "\";");`
`112`	`112`	`}`
`113`	`113`	`}`
`114`	`114`	`producer = new KafkaProducer<String, String>(props);`