Merge pull request #982 from Shopify/consumer/fix-last-stable-offset

consumer: don't check LastStableOffset
IBM · Nov 20, 2017 · 0f6b831 · 0f6b831
2 parents 9ea1af8 + 10f33be
commit 0f6b831
Showing 1 changed file with 0 additions and 5 deletions.
diff --git 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 {