Fix ClassCastException in ChainedKTM

Cast transactionManager to interface KafkaAwareTransactionManager instead of KafkaTransactionManager.
spring-projects · Dec 7, 2021 · 97210dc · 97210dc
1 parent 2dc1568
commit 97210dc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...a/src/main/java/org/springframework/kafka/transaction/ChainedKafkaTransactionManager.java b/...a/src/main/java/org/springframework/kafka/transaction/ChainedKafkaTransactionManager.java
@@ -47,7 +47,7 @@ public ChainedKafkaTransactionManager(PlatformTransactionManager... transactionM
 		for (PlatformTransactionManager tm : transactionManagers) {
 			if (tm instanceof KafkaAwareTransactionManager) {
 				Assert.isNull(uniqueKafkaTransactionManager, "Only one KafkaAwareTransactionManager is allowed");
-				uniqueKafkaTransactionManager = (KafkaTransactionManager<K, V>) tm;
+				uniqueKafkaTransactionManager = (KafkaAwareTransactionManager<K, V>) tm;
 			}
 		}
 		Assert.notNull(uniqueKafkaTransactionManager, "Exactly one KafkaAwareTransactionManager is required");