From a9b0252be382cfcfbc837b4010c0b67aa38eebce Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Thu, 3 Nov 2022 10:08:29 -0400 Subject: [PATCH] Revert KafkaAdmin Change (Previous Commit) (main only). --- .../main/java/org/springframework/kafka/core/KafkaAdmin.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/spring-kafka/src/main/java/org/springframework/kafka/core/KafkaAdmin.java b/spring-kafka/src/main/java/org/springframework/kafka/core/KafkaAdmin.java index b3164cfb..87b50f25 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/core/KafkaAdmin.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/core/KafkaAdmin.java @@ -201,9 +201,6 @@ public class KafkaAdmin extends KafkaResourceFactory addOrModifyTopicsIfNeeded(adminClient, newTopics); return true; } - catch (InterruptedException ex) { - Thread.currentThread().interrupt(); - } catch (Exception ex) { if (!this.initializingContext || this.fatalIfBrokerNotAvailable) { throw new IllegalStateException("Could not configure topics", ex);