[GitHub] [kafka] rhauch commented on a change in pull request #10158: KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException

rhauch commented on a change in pull request #10158: URL: https://github.com/apache/kafka/pull/10158#discussion_r579289580 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java ## @@ -161,6 +164,7 @@ public void start() { //

[GitHub] [kafka] rhauch commented on a change in pull request #10158: KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException

rhauch commented on a change in pull request #10158: URL: https://github.com/apache/kafka/pull/10158#discussion_r579288641 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java ## @@ -366,6 +346,42 @@ private void readToLogEnd() {

[GitHub] [kafka] rhauch commented on a change in pull request #10158: KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException

rhauch commented on a change in pull request #10158: URL: https://github.com/apache/kafka/pull/10158#discussion_r579280518 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java ## @@ -161,6 +164,7 @@ public void start() { //

[GitHub] [kafka] rhauch commented on a change in pull request #10158: KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException

rhauch commented on a change in pull request #10158: URL: https://github.com/apache/kafka/pull/10158#discussion_r578916881 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java ## @@ -390,7 +410,11 @@ public void run() {

[GitHub] [kafka] rhauch commented on a change in pull request #10158: KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException

rhauch commented on a change in pull request #10158: URL: https://github.com/apache/kafka/pull/10158#discussion_r578919850 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java ## @@ -366,6 +348,44 @@ private void readToLogEnd() {

[GitHub] [kafka] rhauch commented on a change in pull request #10158: KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException

rhauch commented on a change in pull request #10158: URL: https://github.com/apache/kafka/pull/10158#discussion_r578917177 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java ## @@ -366,6 +348,44 @@ private void readToLogEnd() {

[GitHub] [kafka] rhauch commented on a change in pull request #10158: KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException

rhauch commented on a change in pull request #10158: URL: https://github.com/apache/kafka/pull/10158#discussion_r578916881 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java ## @@ -390,7 +410,11 @@ public void run() {