From 8e5f2d546ec3b0afa7d37a6903b7e4ab7d75b51d Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 20 Oct 2022 10:59:55 -0400 Subject: [PATCH] checkstyle fixes --- .../binder/kafka/provisioning/KafkaTopicProvisioner.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java index d3ff0713d..31133d58d 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java @@ -263,7 +263,8 @@ public class KafkaTopicProvisioner implements KafkaFuture> 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); } });