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