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 {