Remove call to deprecated method in Spring Kafka

sobychacko · sobychacko · commit e848ec8051fd · 2022-02-15T11:42:46.000-05:00
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
@@ -679,7 +679,7 @@ protected MessageProducer createConsumerEndpoint(
 			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) {

Original file line number	Diff line number	Diff line change
`@@ -679,7 +679,7 @@ protected MessageProducer createConsumerEndpoint(`
`679`	`679`	`concurrency = extendedConsumerProperties.getConcurrency();`
`680`	`680`	`}`
`681`	`681`	`resetOffsetsForAutoRebalance(extendedConsumerProperties, consumerFactory, containerProperties);`
`682`		`- containerProperties.setAuthorizationExceptionRetryInterval(this.configurationProperties.getAuthorizationExceptionRetryInterval());`
	`682`	`+ containerProperties.setAuthExceptionRetryInterval(this.configurationProperties.getAuthorizationExceptionRetryInterval());`
`683`	`683`	`@SuppressWarnings("rawtypes")`
`684`	`684`	`final ConcurrentMessageListenerContainer<?, ?> messageListenerContainer = new ConcurrentMessageListenerContainer(`
`685`	`685`	`consumerFactory, containerProperties) {`