reiseburo
/
verspaetung
mirror of https://github.com/reiseburo/verspaetung
1
0
Fork 0
Code Issues Releases Wiki Activity

nicer logging

This commit is contained in:
Christian Meier 2015-11-09 22:39:19 +01:00
parent dc918a700e
commit 4c655995f9
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/groovy/com/github/reiseburo/verspaetung/KafkaPoller.groovy
View File

@ -159,7 +159,7 @@ class KafkaPoller extends Thread {
*/ */
private void reconnect() { private void reconnect() {
disconnectConsumers() disconnectConsumers()
LOGGER.info('Creating SimpleConsumer connections for brokers') LOGGER.info('Creating SimpleConsumer connections for brokers {}', this.brokers)
synchronized(this.brokers) { synchronized(this.brokers) {
this.brokers.each { Broker b -> this.brokers.each { Broker b ->
SimpleConsumer consumer = new SimpleConsumer(b.host, SimpleConsumer consumer = new SimpleConsumer(b.host,