From 4fb5037fd7d26777fcf01106d34585ee0a4f96ae Mon Sep 17 00:00:00 2001
From: Soby Chacko <schacko@pivotal.io>
Date: Fri, 14 May 2021 11:54:01 -0400
Subject: [PATCH] Use dlqProducerProperties for DLQ topics

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1077
---
 .../binder/kafka/provisioning/KafkaTopicProvisioner.java       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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) {