kfake: fix handling ListOffsets with requested timestamp

twmb · Apr 12, 2024 · 5d8aa1c · 5d8aa1c
1 parent 351e7fa
commit 5d8aa1c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/kfake/02_list_offsets.go b/pkg/kfake/02_list_offsets.go
@@ -75,10 +75,11 @@ func (c *Cluster) handleListOffsets(b *broker, kreq kmsg.Request) (kmsg.Response
 					sp.Offset = pd.highWatermark
 				}
 			default:
+				// returns the index of the first batch _after_ the requested timestamp
 				idx, _ := sort.Find(len(pd.batches), func(idx int) int {
 					maxEarlier := pd.batches[idx].maxEarlierTimestamp
 					switch {
-					case maxEarlier < rp.Timestamp:
+					case maxEarlier > rp.Timestamp:
 						return -1
 					case maxEarlier == rp.Timestamp:
 						return 0