RaidenE1 opened a new pull request, #20284: URL: https://github.com/apache/kafka/pull/20284
Implements a timeout mechanism that waits for missing source topics to be created before failing, instead of immediately throwing exceptions in the new Streams protocol. # Changes - StreamThread.java: Added timeout tracking for missing source topics using maxPollTimeMs as timeout duration - StreamThreadTest.java: Added comprehensive unit tests for timeout functionality - KStreamRepartitionIntegrationTest.java: Updated integration tests to support both classic and streams protocols # Key Features - Waits up to maxPollTimeMs before throwing MissingSourceTopicException - Resets timer only after timeout is reached, not when topic status changes - Handles INCORRECTLY_PARTITIONED_TOPICS status by immediately throwing TopologyException - Works with both processing thread modes (with/without processing threads) # Test Coverage - Unit tests for timeout behavior, recovery scenarios, and both protocol types - Integration tests ensuring end-to-end functionality with parameterized protocol testing - All existing tests continue to pass -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
