From fc184ba4226757250e830c5dedd7a8fb6e7b7e50 Mon Sep 17 00:00:00 2001
From: Soby Chacko <schacko@pivotal.io>
Date: Thu, 19 Nov 2020 19:09:50 -0500
Subject: [PATCH] Setters for fields that need customization

See this commit in core fore details:

https://github.com/spring-cloud/spring-cloud-stream/commit/442c72b37c18ea84d54cb97366072475a3868023
---
 .../kafka/KafkaMessageChannelBinder.java       | 18 +++++++++++++++---
 1 file changed, 15 insertions(+), 3 deletions(-)

diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
index 4a20cc9fd..6e2b86429 100644
--- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
+++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
@@ -213,11 +213,11 @@ public class KafkaMessageChannelBinder extends
 
 	private final TransactionTemplate transactionTemplate;
 
-	private final KafkaBindingRebalanceListener rebalanceListener;
+	private KafkaBindingRebalanceListener rebalanceListener;
 
-	private final DlqPartitionFunction dlqPartitionFunction;
+	private DlqPartitionFunction dlqPartitionFunction;
 
-	private final DlqDestinationResolver dlqDestinationResolver;
+	private DlqDestinationResolver dlqDestinationResolver;
 
 	private final Map<ConsumerDestination, ContainerProperties.AckMode> ackModeInfo = new ConcurrentHashMap<>();
 
@@ -309,6 +309,18 @@ public class KafkaMessageChannelBinder extends
 		this.clientFactoryCustomizer = customizer;
 	}
 
+	public void setRebalanceListener(KafkaBindingRebalanceListener rebalanceListener) {
+		this.rebalanceListener = rebalanceListener;
+	}
+
+	public void setDlqPartitionFunction(DlqPartitionFunction dlqPartitionFunction) {
+		this.dlqPartitionFunction = dlqPartitionFunction;
+	}
+
+	public void setDlqDestinationResolver(DlqDestinationResolver dlqDestinationResolver) {
+		this.dlqDestinationResolver = dlqDestinationResolver;
+	}
+
 	Map<String, TopicInformation> getTopicsInUse() {
 		return this.topicsInUse;
 	}