Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
toddpalino committed May 12, 2016
2 parents 5d95fbd + 5bf9ffd commit 7930a61
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions kafka_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 7930a61

Please sign in to comment.