SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add missing backoff multiplier

Browse Source
This commit is contained in:
amseager
2022-05-26 18:51:25 +03:00
committed by Soby Chacko
parent 605a1b1eda
commit 90e5d5ee8d
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
View File

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