Package org.springframework.kafka.transaction

Class ChainedKafkaTransactionManager<K,​V>

  • Type Parameters:
    K - the key type.
    V - the value type.
    All Implemented Interfaces:
    KafkaAwareTransactionManager<K,​V>, org.springframework.transaction.PlatformTransactionManager, org.springframework.transaction.TransactionManager
    public class ChainedKafkaTransactionManager<K,​V>
extends org.springframework.data.transaction.ChainedTransactionManager
implements KafkaAwareTransactionManager<K,​V>
    A ChainedTransactionManager that has exactly one KafkaAwareTransactionManager in the chain.
    Since:
    2.1.3
    Author:
    Gary Russell

    • Constructor Summary

      Constructors 
      Constructor Description
      ChainedKafkaTransactionManager​(org.springframework.transaction.PlatformTransactionManager... transactionManagers)
      Construct an instance with the provided PlatformTransactionManagers.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      ProducerFactory<K,​V> getProducerFactory()
      Get the producer factory.

      • Methods inherited from class org.springframework.data.transaction.ChainedTransactionManager

        commit, getTransaction, rollback

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

      • Methods inherited from interface org.springframework.transaction.PlatformTransactionManager

        commit, getTransaction, rollback

    • Constructor Detail

      • ChainedKafkaTransactionManager

        public ChainedKafkaTransactionManager​(org.springframework.transaction.PlatformTransactionManager... transactionManagers)
        Construct an instance with the provided PlatformTransactionManagers.
        Parameters:
        transactionManagers - the transaction managers.