bbejeck opened a new pull request, #22709: URL: https://github.com/apache/kafka/pull/22709
RocksDBTransactionBuffer's staging map (AbstractTransactionBuffer.pendingWrites) is keyed by key bytes only, with no column-family dimension. Writes to the offsets column family (the "position" key, written when the store persists its Position) are staged into that shared map and then surface in data-column-family range()/all() scans. The outer-join ListValueStore tries to deserialize the 40-byte serialized Position as a value list and fails. The get() methods was already gated against the offsets CF; the iterator paths were not. Non-transactional stores write straight to the offsets CF and never leak, which is why it's transactional-only. -- 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]
