We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8c2b325 commit a9b0252Copy full SHA for a9b0252
spring-kafka/src/main/java/org/springframework/kafka/core/KafkaAdmin.java
@@ -201,9 +201,6 @@ public final boolean initialize() {
201
addOrModifyTopicsIfNeeded(adminClient, newTopics);
202
return true;
203
}
204
- catch (InterruptedException ex) {
205
- Thread.currentThread().interrupt();
206
- }
207
catch (Exception ex) {
208
if (!this.initializingContext || this.fatalIfBrokerNotAvailable) {
209
throw new IllegalStateException("Could not configure topics", ex);
0 commit comments