diff --git a/src/main/groovy/com/github/reiseburo/verspaetung/KafkaPoller.groovy b/src/main/groovy/com/github/reiseburo/verspaetung/KafkaPoller.groovy index d9175aa..5030826 100644 --- a/src/main/groovy/com/github/reiseburo/verspaetung/KafkaPoller.groovy +++ b/src/main/groovy/com/github/reiseburo/verspaetung/KafkaPoller.groovy @@ -159,7 +159,7 @@ class KafkaPoller extends Thread { */ private void reconnect() { disconnectConsumers() - LOGGER.info('Creating SimpleConsumer connections for brokers') + LOGGER.info('Creating SimpleConsumer connections for brokers {}', this.brokers) synchronized(this.brokers) { this.brokers.each { Broker b -> SimpleConsumer consumer = new SimpleConsumer(b.host,