topicctl bug fix for offsets

segmentio · Dec 13, 2023 · c425205 · c425205
1 parent 8ad90a7
commit c425205
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/pkg/messages/bounds.go b/pkg/messages/bounds.go
@@ -179,7 +179,7 @@ func GetPartitionBounds(
 			"Moving first offset forward to match min offset (%d)",
 			minOffset,
 		)
-		firstOffset = minOffset
+		firstOffset = minOffset - 1
 	}
 
 	var firstMessage kafka.Message
@@ -233,11 +233,18 @@ func GetPartitionBounds(
 		)
 	}
 
+	log.Debugf(
+		"Final offsets for %d: %d->%d",
+		partition,
+		firstMessage.Offset,
+		lastMessage.Offset,
+	)
+
 	return Bounds{
 		Partition:   partition,
 		FirstOffset: firstMessage.Offset,
 		FirstTime:   firstMessage.Time,
-		LastOffset:  lastMessage.Offset,
+		LastOffset:  lastMessage.Offset + 1,
 		LastTime:    lastMessage.Time,
 	}, nil
 }