nicktelford opened a new pull request, #22750: URL: https://github.com/apache/kafka/pull/22750
Extends `PositionRestartIntegrationTest` to run every store type and configuration with transactional state stores both enabled and disabled. This exercises interactive-query position consistency and, crucially, position recovery on restart for transactional stores — the end-to-end coverage for the series of transactional state-store position fixes (KAFKA-20760). Also adds unit tests for `InMemoryWindowStore` and `InMemorySessionStore`, mirroring the existing `InMemoryKeyValueStore` test: each verifies that a transactional store exposes its staged (uncommitted) position via a READ_UNCOMMITTED query and via `getPosition()` before commit, and its committed position after commit. -- 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]
