fix: default configuration
This commit is contained in:
@@ -30,6 +30,11 @@ public class MainPlugin extends JavaPlugin {
|
||||
}
|
||||
|
||||
private void initKafkaService() {
|
||||
getLogger().info(String.format(
|
||||
"Kafka settings: [hosts: %s; topic: %s; duration %d]",
|
||||
config.getHosts(), config.getTopic(), config.getDuration()
|
||||
));
|
||||
|
||||
ClassLoader originalContext = Thread.currentThread().getContextClassLoader();
|
||||
Thread.currentThread().setContextClassLoader(null);
|
||||
service = new KafkaService(config.getHosts(), config.getTopic(), config.getDuration());
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
kafka:
|
||||
hosts: [ '127.0.0.1:9022' ]
|
||||
hosts: [ '127.0.0.1:9092' ]
|
||||
topic: 'global-chat'
|
||||
duration: 1000
|
||||
|
||||
|
||||
Reference in New Issue
Block a user