クラス KafkaResourceHolder<K,V>
java.lang.ObjectSE
org.springframework.transaction.support.ResourceHolderSupport
org.springframework.kafka.core.KafkaResourceHolder<K,V>
- 型パラメーター:
K- 鍵の型。V- 値の型。
- 実装されたすべてのインターフェース:
ResourceHolder
Kafka プロデューサーをラップする Kafka リソースホルダー。KafkaTransactionManager は、特定の Kafka プロデューサーファクトリについて、このクラスのインスタンスをスレッドにバインドします。
- 作成者:
- Gary Russell
コンストラクターの概要
コンストラクターコンストラクター説明KafkaResourceHolder(org.apache.kafka.clients.producer.Producer<K, V> producer, DurationSE closeTimeout) プロデューサーのインスタンスを作成します。メソッドのサマリー
クラス org.springframework.transaction.support.ResourceHolderSupport から継承されたメソッド
clear, getDeadline, getTimeToLiveInMillis, getTimeToLiveInSeconds, hasTimeout, isOpen, isRollbackOnly, isSynchronizedWithTransaction, isVoid, released, requested, reset, resetRollbackOnly, setRollbackOnly, setSynchronizedWithTransaction, setTimeoutInMillis, setTimeoutInSeconds, unbound
コンストラクターの詳細
KafkaResourceHolder
public KafkaResourceHolder(org.apache.kafka.clients.producer.Producer<K, V> producer, DurationSE closeTimeout) プロデューサーのインスタンスを作成します。- パラメーター:
producer- プロデューサー。closeTimeout- クローズタイムアウト。
メソッドの詳細
getProducer
commit
public void commit()close
public void close()rollback
public void rollback()