org.springframework.kafka.transaction

Class ChainedKafkaTransactionManager<K,V>

java.lang.Object

org.springframework.data.transaction.ChainedTransactionManager

org.springframework.kafka.transaction.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.support.ResourceTransactionManager

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 and Description
ChainedKafkaTransactionManager(org.springframework.transaction.PlatformTransactionManager... transactionManagers)

Method Summary

Modifier and Type	Method and Description
ProducerFactory<K,V>	getProducerFactory() Get the producer factory.
java.lang.Object	getResourceFactory() Deprecated. - in a future release KafkaAwareTransactionManager will not be a sub interface of ResourceTransactionManager. TODO: Remove in 3.0

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)

Method Detail

getProducerFactory

public ProducerFactory<K,V> getProducerFactory()

Description copied from interface: KafkaAwareTransactionManager

Get the producer factory.

Specified by:

getProducerFactory in interface KafkaAwareTransactionManager<K,V>

Returns:

the producerFactory

getResourceFactory

@Deprecated
public java.lang.Object getResourceFactory()

Deprecated. - in a future release KafkaAwareTransactionManager will not be a sub interface of ResourceTransactionManager. TODO: Remove in 3.0

Return the producer factory.

Specified by:

getResourceFactory in interface org.springframework.transaction.support.ResourceTransactionManager

Returns:

the producer factory.