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<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);
 			}
 		});