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 519883c6..ade07741 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
@@ -310,9 +310,10 @@ public class KafkaTopicProvisioner implements
 					? partitions
 					: properties.getExtension().getDlqPartitions();
 			try {
+				final KafkaProducerProperties dlqProducerProperties = properties.getExtension().getDlqProducerProperties();
 				createTopicAndPartitions(adminClient, dlqTopic, dlqPartitions,
 						properties.getExtension().isAutoRebalanceEnabled(),
-						properties.getExtension().getTopic());
+						dlqProducerProperties.getTopic());
 			}
 			catch (Throwable throwable) {
 				if (throwable instanceof Error) {