Fix ClassCastException in ChainedKTM

jorritvdven · garyrussell · commit 35f18278a4b9 · 2021-12-07T10:09:28.000-05:00
Cast transactionManager to interface KafkaAwareTransactionManager instead of KafkaTransactionManager.
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/transaction/ChainedKafkaTransactionManager.java b/spring-kafka/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");

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ public ChainedKafkaTransactionManager(PlatformTransactionManager... transactionM`
`47`	`47`	`for (PlatformTransactionManager tm : transactionManagers) {`
`48`	`48`	`if (tm instanceof KafkaAwareTransactionManager) {`
`49`	`49`	`Assert.isNull(uniqueKafkaTransactionManager, "Only one KafkaAwareTransactionManager is allowed");`
`50`		`- uniqueKafkaTransactionManager = (KafkaTransactionManager<K, V>) tm;`
	`50`	`+ uniqueKafkaTransactionManager = (KafkaAwareTransactionManager<K, V>) tm;`
`51`	`51`	`}`
`52`	`52`	`}`
`53`	`53`	`Assert.notNull(uniqueKafkaTransactionManager, "Exactly one KafkaAwareTransactionManager is required");`