diff --git a/build.gradle b/build.gradle index 6db8f69..eef237b 100644 --- a/build.gradle +++ b/build.gradle @@ -7,7 +7,7 @@ apply plugin: 'application' group = "com.github.lookout" description = "A utility for monitoring the delay of Kafka consumers" -version = '0.1.6' +version = '0.1.7' mainClassName = 'com.github.lookout.verspaetung.Main' defaultTasks 'clean', 'check' sourceCompatibility = '1.7' diff --git a/src/main/groovy/com/github/lookout/verspaetung/metrics/ConsumerGauge.groovy b/src/main/groovy/com/github/lookout/verspaetung/metrics/ConsumerGauge.groovy index fad3c24..d6a590f 100644 --- a/src/main/groovy/com/github/lookout/verspaetung/metrics/ConsumerGauge.groovy +++ b/src/main/groovy/com/github/lookout/verspaetung/metrics/ConsumerGauge.groovy @@ -8,6 +8,9 @@ import org.coursera.metrics.datadog.Tagged import com.github.lookout.verspaetung.KafkaConsumer import com.github.lookout.verspaetung.TopicPartition +import org.slf4j.Logger +import org.slf4j.LoggerFactory + /** * Dropwizard Metrics Gauge for reporting the value of a given KafkaConsumer */ @@ -18,6 +21,8 @@ class ConsumerGauge implements Gauge, Tagged { protected AbstractMap topics private TopicPartition topicPartition + private Logger logger = LoggerFactory.getLogger(ConsumerGauge.class) + ConsumerGauge(KafkaConsumer consumer, AbstractMap consumers, AbstractMap topics) { @@ -42,7 +47,7 @@ class ConsumerGauge implements Gauge, Tagged { return ["partition:${this.consumer.partition}", "topic:${this.consumer.topic}", "consumer-group:${this.consumer.name}" - ].collect { s -> s.strings.join('') } + ].collect { s -> s.toString() } } /**