Merge pull request #70 from icebourg/topic_error_handling

Log an error message when we encounter trouble with getting leader info
linkedin · May 11, 2016 · 5bf9ffd · 5bf9ffd
2 parents ba73de4 + cd2f05c
commit 5bf9ffd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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 {