Skip to content

Commit 6e8d2ad

Browse files
committed
modify kafka default config file name
1 parent c1fe3bd commit 6e8d2ad

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ private KafkaProducer createProducer(int eventType){
9797
props.put("bootstrap.servers", this.serverAddress);
9898
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
9999
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
100-
String defaultConfig = "kafka.config";
100+
String defaultConfig = "kafka.conf";
101101
File configFile = new File(defaultConfig);
102102
if(configFile.exists()) {
103103
Config config = ConfigFactory.load(defaultConfig);

0 commit comments

Comments
 (0)