From d37e785a7d5f454f3058aeb0ffdd71ca96ebea37 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 | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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 48b9e339f..d3d5d4b32 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 @@ -203,8 +203,8 @@ public class KafkaTopicProvisioner implements } } private ConsumerDestination doProvisionConsumerDestination(final String name, - final String group, - ExtendedConsumerProperties properties) { + final String group, + ExtendedConsumerProperties properties) { final KafkaConsumerDestination kafkaConsumerDestination = new KafkaConsumerDestination(name); if (properties.getExtension().isDestinationIsPattern()) { Assert.isTrue(!properties.getExtension().isEnableDlq(), @@ -262,7 +262,8 @@ public class KafkaTopicProvisioner implements .describeTopics(Collections.singletonList(topicName)); KafkaFuture> all = describeTopicsResult.all(); return all.get(this.operationTimeout, TimeUnit.SECONDS); - } catch (Exception ex) { + } + catch (Exception ex) { throw new ProvisioningException("Problems encountered with partitions finding for: " + topicName, ex); } });