Set HWMO during creation of partitionConsumer

agriffaut · Dec 5, 2021 · 179dc9d · 179dc9d
1 parent 1c4079e
commit 179dc9d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/consumer.go b/consumer.go
@@ -400,6 +400,9 @@ func (child *partitionConsumer) chooseStartingOffset(offset int64) error {
 	if err != nil {
 		return err
 	}
+
+	child.highWaterMarkOffset = newestOffset
+
 	oldestOffset, err := child.consumer.client.GetOffset(child.topic, child.partition, OffsetOldest)
 	if err != nil {
 		return err