Merge pull request twmb#707 from narqo/kfake-listoffsets-ts

kfake: fix handling ListOffsets when Timestamp is requested
peczenyj · Apr 12, 2024 · 6a58760 · 6a58760
2 parents 351e7fa + 5d8aa1c
commit 6a58760
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