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; }