ErrDataLoss: use the new offset **after** we create the error

twmb · Sep 20, 2021 · f6a8c9a · f6a8c9a
1 parent 43cdcad
commit f6a8c9a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kgo/consumer.go b/pkg/kgo/consumer.go
@@ -1569,8 +1569,8 @@ func (cl *Client) loadEpochsForBrokerLoad(ctx context.Context, broker *broker, l
 			offset := loadPart.at
 			var err error
 			if rPartition.EndOffset < offset {
-				offset = rPartition.EndOffset
 				err = &ErrDataLoss{topic, partition, offset, rPartition.EndOffset}
+				offset = rPartition.EndOffset
 			}
 
 			loaded.add(loadedOffset{