diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java b/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java
index 9b8932950..4749340e0 100644
--- a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java
+++ b/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java
@@ -423,7 +423,7 @@ public class KafkaTopicProvisioner implements ProvisioningProvider<ExtendedConsu
 							}
 							catch (ExecutionException ex) {
 								if (ex.getCause() instanceof UnknownTopicOrPartitionException) {
-									throw new Exception(ex.getCause());
+									throw (UnknownTopicOrPartitionException)ex.getCause();
 								} else {
 									logger.warn("No partitions have been retrieved for the topic (" + topicName + "). This will affect the health check.");
 								}