Merge pull request #12 from sesamzoo/accept-empty-offsets-map

Accept empty map of offsets instead of throwing

Author: omarsmak

src/main/kotlin/com/omarsmak/kafka/consumer/lag/monitoring/client/impl/KafkaConsumerLagJavaClient.kt

@@ -31,7 +31,7 @@ internal class KafkaConsumerLagJavaClient (
         val offsets = javaAdminClient.listConsumerGroupOffsets(consumerGroup)
                 .partitionsToOffsetAndMetadata()
                 .get()
-        if (offsets == null || offsets.isEmpty())
+        if (offsets == null)
             throw KafkaConsumerLagClientException("Consumer group `$consumerGroup` does not exist in the Kafka cluster.")
 
         return getConsumerOffsetsPerTopic(offsets)