nicktelford opened a new pull request, #22312: URL: https://github.com/apache/kafka/pull/22312
The cache holds uncommitted writes that must not be visible under READ_COMMITTED, so that isolation level bypasses the cache entirely and delegates straight to the inner store's readOnly view. READ_UNCOMMITTED requires a merged view of both cache and store, so a ReadOnlyView inner class is introduced that reuses the rangeInternal/allInternal/ prefixScanInternal helpers extracted from the public methods. getInternal is refactored to accept an explicit underlying store so that the ReadOnlyView can share the same cache-merge logic without duplicating the MergedSortedCache wiring, keeping the view consistent with the store's own point-lookup semantics as the implementation evolves. The null-check, store-open guard, and locking are consolidated into getInternal itself so that both the public get() and the ReadOnlyView's get() share the same precondition and synchronisation behaviour. KAFKA-20497 -- 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]
