From 10f33bec2a197228028b23574fe9522c7993a2f0 Mon Sep 17 00:00:00 2001 From: Evan Huus Date: Fri, 17 Nov 2017 11:20:18 -0500 Subject: [PATCH] consumer: don't check LastStableOffset It's only needed for transactions (which we don't support yet) and the logic was wrong anyway. Fixes slow consuming for certain Kafka 0.11 configurations. --- consumer.go | 5 ----- 1 file changed, 5 deletions(-) diff --git a/consumer.go b/consumer.go index cb6f031d0..ab8bb80b5 100644 --- a/consumer.go +++ b/consumer.go @@ -546,11 +546,6 @@ func (child *partitionConsumer) parseRecords(block *FetchResponseBlock) ([]*Cons } else { incomplete = true } - - if child.offset > block.LastStableOffset { - // We reached the end of closed transactions - break - } } if incomplete || len(messages) == 0 {