From e848ec8051fd17b78ba77b409ccd0853066cdb77 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 15 Feb 2022 11:42:46 -0500 Subject: [PATCH] Remove call to deprecated method in Spring Kafka --- .../cloud/stream/binder/kafka/KafkaMessageChannelBinder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java index 6a4973de..e0ff6c06 100644 --- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java +++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java @@ -679,7 +679,7 @@ public class KafkaMessageChannelBinder extends concurrency = extendedConsumerProperties.getConcurrency(); } resetOffsetsForAutoRebalance(extendedConsumerProperties, consumerFactory, containerProperties); - containerProperties.setAuthorizationExceptionRetryInterval(this.configurationProperties.getAuthorizationExceptionRetryInterval()); + containerProperties.setAuthExceptionRetryInterval(this.configurationProperties.getAuthorizationExceptionRetryInterval()); @SuppressWarnings("rawtypes") final ConcurrentMessageListenerContainer messageListenerContainer = new ConcurrentMessageListenerContainer( consumerFactory, containerProperties) {