File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed
plugins/kafkaplugin/src/main/java/org/tron/eventplugin Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -99,7 +99,9 @@ private KafkaProducer createProducer(int eventType){
99
99
props .put ("value.serializer" , "org.apache.kafka.common.serialization.StringSerializer" );
100
100
String defaultConfig = "kafka.conf" ;
101
101
File configFile = new File (defaultConfig );
102
+ log .error ("after configFile" );
102
103
if (configFile .exists ()) {
104
+ log .error ("in configFile" );
103
105
Config config = ConfigFactory .load (defaultConfig );
104
106
if (config .hasPath ("authorization.user" ) && config .hasPath ("authorization.passwd" )) {
105
107
String user = config .getString ("authorization.user" );
@@ -109,8 +111,12 @@ private KafkaProducer createProducer(int eventType){
109
111
props .put ("sasl.jaas.config" ,
110
112
"org.apache.kafka.common.security.scram.ScramLoginModule required username=\" " +
111
113
user + "\" password=\" " + passwd + "\" ;" );
114
+
115
+ log .error ("org.apache.kafka.common.security.scram.ScramLoginModule required username=\" " +
116
+ user + "\" password=\" " + passwd + "\" ;" );
112
117
}
113
118
}
119
+ log .error ("after configFile" );
114
120
producer = new KafkaProducer <String , String >(props );
115
121
116
122
producerMap .put (eventType , producer );
You can’t perform that action at this time.
0 commit comments