Jess668 opened a new pull request, #22975: URL: https://github.com/apache/kafka/pull/22975
The read-only-record iterators backing the headers-aware IQv2 query types (`MeteredSessionStoreWithHeaders`, `MeteredTimestampedWindowStoreWithHeaders`, `MeteredTimestampedKeyValueStoreWithHeaders`) each hand-rolled the same metering lifecycle: stamping the open time, registering in numOpenIterators/openIterators, and recording the operation and iterator-duration sensors on close. Only `next()` genuinely differs per store. Extract that lifecycle into a shared `AbstractMeteredReadOnlyRecordIterator<RawKey, K, V>`. Each store's iterator now extends it and implements only `next()`. -- 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]
