Cast transactionManager to interface KafkaAwareTransactionManager instead of KafkaTransactionManager.

jorritvdven · garyrussell · commit 60e21e0642e9 · 2021-12-07T10:06:44.000-05:00
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
@@ -50,7 +50,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
`@@ -50,7 +50,7 @@ public ChainedKafkaTransactionManager(PlatformTransactionManager... transactionM`
`50`	`50`	`for (PlatformTransactionManager tm : transactionManagers) {`
`51`	`51`	`if (tm instanceof KafkaAwareTransactionManager) {`
`52`	`52`	`Assert.isNull(uniqueKafkaTransactionManager, "Only one KafkaAwareTransactionManager is allowed");`
`53`		`- uniqueKafkaTransactionManager = (KafkaTransactionManager<K, V>) tm;`
	`53`	`+ uniqueKafkaTransactionManager = (KafkaAwareTransactionManager<K, V>) tm;`
`54`	`54`	`}`
`55`	`55`	`}`
`56`	`56`	`Assert.notNull(uniqueKafkaTransactionManager, "Exactly one KafkaAwareTransactionManager is required");`