SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

checkstyle fixes

Browse Source
This commit is contained in:
Soby Chacko
2022-10-20 10:59:55 -04:00
parent cc04b0b13b
commit 8e5f2d546e
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java
View File

@@ -263,7 +263,8 @@ public class KafkaTopicProvisioner implements
KafkaFuture<Map<String, TopicDescription>> all = describeTopicsResult
.allTopicNames();
return all.get(this.operationTimeout, TimeUnit.SECONDS);
} catch (Exception ex) {
}
catch (Exception ex) {
throw new ProvisioningException("Problems encountered with partitions finding for: " + topicName, ex);
}
});