Package org.springframework.kafka.core
Class KafkaResourceHolder<K,V>
java.lang.Object
org.springframework.transaction.support.ResourceHolderSupport
org.springframework.kafka.core.KafkaResourceHolder<K,V>
- Type Parameters:
K
- the key type.V
- the value type.
- All Implemented Interfaces:
ResourceHolder
Kafka resource holder, wrapping a Kafka producer. KafkaTransactionManager binds instances of this
class to the thread, for a given Kafka producer factory.
- Author:
- Gary Russell
-
Constructor Summary
ConstructorDescriptionKafkaResourceHolder
(org.apache.kafka.clients.producer.Producer<K, V> producer, Duration closeTimeout) Construct an instance for the producer. -
Method Summary
Methods inherited from class org.springframework.transaction.support.ResourceHolderSupport
clear, getDeadline, getTimeToLiveInMillis, getTimeToLiveInSeconds, hasTimeout, isOpen, isRollbackOnly, isSynchronizedWithTransaction, isVoid, released, requested, reset, resetRollbackOnly, setRollbackOnly, setSynchronizedWithTransaction, setTimeoutInMillis, setTimeoutInSeconds, unbound
-
Constructor Details
-
Method Details
-
getProducer
-
commit
public void commit() -
close
public void close() -
rollback
public void rollback()
-