Russole opened a new pull request, #23415: URL: https://github.com/apache/kafka/pull/23415
This PR removes the redundant `inputPosition` assertion and replaces the input-topic consumer wait with a position-bounded versioned-key query. The previous check only confirmed that the updated record was available in the input topic, whereas the new query confirms that the local versioned store has processed offset 4 and contains the updated value `999999`. This ensures that the snapshot semantics check runs only after the store has processed the update. Unused consumer-related imports are also removed. -- 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]
