From f6a8c9a91810a3fa6ace86533350b03584062937 Mon Sep 17 00:00:00 2001
From: Travis Bischel <travis.bischel+github@gmail.com>
Date: Mon, 20 Sep 2021 12:33:19 -0600
Subject: [PATCH] ErrDataLoss: use the new offset **after** we create the error

---
 pkg/kgo/consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/kgo/consumer.go b/pkg/kgo/consumer.go
index f93f3cfb..ef8c957a 100644
--- 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{