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);