RaidenE1 opened a new pull request, #20123: URL: https://github.com/apache/kafka/pull/20123
- Background: In the old protocol, Kafka Streams used to throw a `MissingSourceTopicException` when a source topic is missing. In the new protocol, it doesn’t do that anymore, while only log the status that is returned from the broker, which contains a status that indicates that a source topic is missing. - What I do: 1. Throw an `MissingSourceTopicException` when source topic is missing 2. Add unittests 3. Modify integration tests to fit both old and new protocols -- 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
