From 90e5d5ee8deb316209bc317c4cf9a8f39988594f Mon Sep 17 00:00:00 2001
From: amseager <amseager@mail.ru>
Date: Thu, 26 May 2022 18:51:25 +0300
Subject: [PATCH] add missing backoff multiplier

---
 .../cloud/stream/binder/kafka/KafkaMessageChannelBinder.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
index 3716c0a28..beafadb6a 100644
--- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
+++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
@@ -785,9 +785,11 @@ public class KafkaMessageChannelBinder extends
 		}
 		int initialInterval = extendedConsumerProperties.getBackOffInitialInterval();
 		int maxInterval = extendedConsumerProperties.getBackOffMaxInterval();
+		double multiplier = extendedConsumerProperties.getBackOffMultiplier();
 		ExponentialBackOff backOff = new ExponentialBackOffWithMaxRetries(maxAttempts - 1);
 		backOff.setInitialInterval(initialInterval);
 		backOff.setMaxInterval(maxInterval);
+		backOff.setMultiplier(multiplier);
 		return backOff;
 	}