diff --git a/src/main/java/ru/dmitriymx/minecraft/globalchat/MainPlugin.java b/src/main/java/ru/dmitriymx/minecraft/globalchat/MainPlugin.java index 531f8b8..2d24a70 100644 --- a/src/main/java/ru/dmitriymx/minecraft/globalchat/MainPlugin.java +++ b/src/main/java/ru/dmitriymx/minecraft/globalchat/MainPlugin.java @@ -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()); diff --git a/src/main/resources/config.yml b/src/main/resources/config.yml index 504c4a0..f7e11b0 100644 --- a/src/main/resources/config.yml +++ b/src/main/resources/config.yml @@ -1,5 +1,5 @@ kafka: - hosts: [ '127.0.0.1:9022' ] + hosts: [ '127.0.0.1:9092' ] topic: 'global-chat' duration: 1000