Formatting code for bounds.go

segmentio · Feb 1, 2024 · 0fabb10 · 0fabb10
1 parent 35f1d40
commit 0fabb10
Showing 1 changed file with 9 additions and 16 deletions.
diff --git a/pkg/messages/bounds.go b/pkg/messages/bounds.go
@@ -174,22 +174,15 @@ func GetPartitionBounds(
 		}, nil
 	}
 
-	if minOffset > firstOffset {
-		// if minOffset is equal to lastOffset
-		// We read message (firstMessage) from minOffset+1 Which can lead to invalid reads
-		// Hence, We will not move first offset to match min offset
-		if minOffset >= lastOffset {
-			log.Debugf(
-				"Not Moving first offset forward to match min offset (%d) since minOffset is equal to lastOffset",
-				minOffset,
-			)
-		} else {
-			log.Debugf(
-				"Moving first offset forward to match min offset (%d)",
-				minOffset,
-			)
-			firstOffset = minOffset
-		}
+	// if minOffset is equal to lastOffset
+	// We read message (firstMessage) from minOffset+1 Which can lead to invalid reads
+	// Hence, We will not move first offset to match min offset if minOffset >= lastOffset
+	if minOffset > firstOffset && minOffset < lastOffset {
+		log.Debugf(
+			"Moving first offset forward to match min offset (%d)",
+			minOffset,
+		)
+		firstOffset = minOffset
 	}
 
 	var firstMessage kafka.Message