K
- the key type.V
- the value type.public class ChainedKafkaTransactionManager<K,V> extends org.springframework.data.transaction.ChainedTransactionManager implements KafkaAwareTransactionManager<K,V>
ChainedTransactionManager
that has exactly one
KafkaAwareTransactionManager
in the chain.Constructor and Description |
---|
ChainedKafkaTransactionManager(org.springframework.transaction.PlatformTransactionManager... transactionManagers)
Construct an instance with the provided
PlatformTransactionManager s. |
Modifier and Type | Method and Description |
---|---|
ProducerFactory<K,V> |
getProducerFactory()
Get the producer factory.
|
commit, getTransaction, rollback
public ChainedKafkaTransactionManager(org.springframework.transaction.PlatformTransactionManager... transactionManagers)
PlatformTransactionManager
s.transactionManagers
- the transaction managers.public ProducerFactory<K,V> getProducerFactory()
KafkaAwareTransactionManager
getProducerFactory
in interface KafkaAwareTransactionManager<K,V>