K - the key type.V - the value type.public class KafkaResourceHolder<K,V>
extends org.springframework.transaction.support.ResourceHolderSupport
| Constructor and Description |
|---|
KafkaResourceHolder(org.apache.kafka.clients.producer.Producer<K,V> producer)
Construct an instance for the producer.
|
KafkaResourceHolder(org.apache.kafka.clients.producer.Producer<K,V> producer,
java.time.Duration closeTimeout)
Construct an instance for the producer.
|
KafkaResourceHolder(org.apache.kafka.clients.producer.Producer<K,V> producer,
long closeTimeout)
Deprecated.
in favor of
KafkaResourceHolder(Producer, Duration) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
commit() |
org.apache.kafka.clients.producer.Producer<K,V> |
getProducer() |
void |
rollback() |
clear, getDeadline, getTimeToLiveInMillis, getTimeToLiveInSeconds, hasTimeout, isOpen, isRollbackOnly, isSynchronizedWithTransaction, isVoid, released, requested, reset, resetRollbackOnly, setRollbackOnly, setSynchronizedWithTransaction, setTimeoutInMillis, setTimeoutInSeconds, unboundpublic KafkaResourceHolder(org.apache.kafka.clients.producer.Producer<K,V> producer)
producer - the producer.@Deprecated public KafkaResourceHolder(org.apache.kafka.clients.producer.Producer<K,V> producer, long closeTimeout)
KafkaResourceHolder(Producer, Duration)producer - the producer.closeTimeout - the close timeout.