[GitHub] [kafka] cadonna commented on a change in pull request #11686: KAFKA-12648: invoke exception handler for MissingSourceTopicException with named topologies

2022-01-21 Thread GitBox
cadonna commented on a change in pull request #11686: URL: https://github.com/apache/kafka/pull/11686#discussion_r789633567 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java ## @@ -97,49 +101,74 @@ public boolean setup() {

[GitHub] [kafka] cadonna commented on a change in pull request #11686: KAFKA-12648: invoke exception handler for MissingSourceTopicException with named topologies

2022-01-20 Thread GitBox
cadonna commented on a change in pull request #11686: URL: https://github.com/apache/kafka/pull/11686#discussion_r788668651 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java ## @@ -511,15 +512,21 @@ private

[GitHub] [kafka] cadonna commented on a change in pull request #11686: KAFKA-12648: invoke exception handler for MissingSourceTopicException with named topologies

2022-01-20 Thread GitBox
cadonna commented on a change in pull request #11686: URL: https://github.com/apache/kafka/pull/11686#discussion_r788604115 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java ## @@ -97,49 +101,74 @@ public boolean setup() {

[GitHub] [kafka] cadonna commented on a change in pull request #11686: KAFKA-12648: invoke exception handler for MissingSourceTopicException with named topologies

2022-01-20 Thread GitBox
cadonna commented on a change in pull request #11686: URL: https://github.com/apache/kafka/pull/11686#discussion_r788604115 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java ## @@ -97,49 +101,74 @@ public boolean setup() {

[GitHub] [kafka] cadonna commented on a change in pull request #11686: KAFKA-12648: invoke exception handler for MissingSourceTopicException with named topologies

2022-01-20 Thread GitBox
cadonna commented on a change in pull request #11686: URL: https://github.com/apache/kafka/pull/11686#discussion_r788563612 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -523,16 +528,21 @@ private boolean wrappedExceptionIsIn(final

[GitHub] [kafka] cadonna commented on a change in pull request #11686: KAFKA-12648: invoke exception handler for MissingSourceTopicException with named topologies

2022-01-19 Thread GitBox
cadonna commented on a change in pull request #11686: URL: https://github.com/apache/kafka/pull/11686#discussion_r787544943 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java ## @@ -515,11 +518,23 @@ private