From 0d2697449e5a7784ccd921e2cd25b9920e5a7390 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 66de49146..b0932c93f 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
@@ -838,9 +838,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;
 	}