frankvicky opened a new pull request, #21736:
URL: https://github.com/apache/kafka/pull/21736
Fixes bugs where `MeteredTimestampedKeyValueStoreWithHeaders` iterator
methods fail when key deserializers require headers.
The class inherits iterator-returning methods from `MeteredKeyValueStore`:
- `range(K, K)` / `reverseRange(K, K)`
- `all()` / `reverseAll()`
- `prefixScan(P, PS)`
These methods use `deserializeKey(rawKey)` which calls
`serdes.keyFrom(rawKey, internalContext.headers())`, using the current
processing context's headers instead of each record's own headers.
Additionally, the `peekNextKey()` implementation in iterator classes
deserializes keys with empty headers.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
