From cd2f05ce561b40dfccf05d2453528165e0d41b26 Mon Sep 17 00:00:00 2001
From: AJ Bourg <aj@ajbourg.com>
Date: Wed, 11 May 2016 15:01:38 -0600
Subject: [PATCH] Log an error message when we encounter trouble with getting
 leader information.

---
 kafka_client.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/kafka_client.go b/kafka_client.go
index 605446d5..12ed9a5a 100644
--- a/kafka_client.go
+++ b/kafka_client.go
@@ -185,6 +185,7 @@ func (client *KafkaClient) getOffsets() error {
 			broker, err := client.client.Leader(topic, int32(i))
 			if err != nil {
 				client.topicMapLock.RUnlock()
+				log.Errorf("Topic leader error on %s:%v: %v", topic, int32(i), err)
 				return err
 			}
 			if _, ok := requests[broker.ID()]; !ok {