Revert KafkaAdmin Change (Previous Commit)

(main only).
2022-11-03 10:08:29 -04:00
parent 8c2b325600
commit a9b0252be3
1 changed files with 0 additions and 3 deletions
--- 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);