GH-2363: Fix Class Cast in ErrorHandlerAdapter

garyrussell · garyrussell · commit b6b4c1aee65e · 2022-07-21T12:52:23.000-04:00
Resolves #2363
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/ErrorHandlerAdapter.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/ErrorHandlerAdapter.java
@@ -163,7 +163,7 @@ public void handleBatch(Exception thrownException, ConsumerRecords<?, ?> data, C
 	@Override
 	public void onPartitionsAssigned(Consumer<?, ?> consumer, Collection<TopicPartition> partitions) {
 		if (this.batchErrorHandler instanceof RetryingBatchErrorHandler) {
-			((FallbackBatchErrorHandler) this.batchErrorHandler).onPartitionsAssigned(consumer, partitions);
+			((RetryingBatchErrorHandler) this.batchErrorHandler).onPartitionsAssigned(consumer, partitions);
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -163,7 +163,7 @@ public void handleBatch(Exception thrownException, ConsumerRecords<?, ?> data, C`
`163`	`163`	`@Override`
`164`	`164`	`public void onPartitionsAssigned(Consumer<?, ?> consumer, Collection<TopicPartition> partitions) {`
`165`	`165`	`if (this.batchErrorHandler instanceof RetryingBatchErrorHandler) {`
`166`		`- ((FallbackBatchErrorHandler) this.batchErrorHandler).onPartitionsAssigned(consumer, partitions);`
	`166`	`+ ((RetryingBatchErrorHandler) this.batchErrorHandler).onPartitionsAssigned(consumer, partitions);`
`167`	`167`	`}`
`168`	`168`	`}`
`169`	`169`