クラス CompositeProducerInterceptor<K,V>
java.lang.ObjectSE
org.springframework.kafka.support.CompositeProducerInterceptor<K,V>
- 型パラメーター:
K
- 鍵の型。V
- 値の型。
- 実装されたすべてのインターフェース:
CloseableSE
、AutoCloseableSE
、org.apache.kafka.clients.producer.ProducerInterceptor<K,
、V> org.apache.kafka.common.Configurable
public class CompositeProducerInterceptor<K,V>
extends ObjectSE
implements org.apache.kafka.clients.producer.ProducerInterceptor<K,V>, CloseableSE
インターセプターのコレクションに委譲する
ProducerInterceptor
。- 導入:
- 3.0
- 作成者:
- Soby Chacko
コンストラクターのサマリー
コンストラクターコンストラクター説明CompositeProducerInterceptor
(org.apache.kafka.clients.producer.ProducerInterceptor<K, V>... delegates) 提供されたProducerInterceptor
へのデリゲートを使用してインスタンスを構築します。メソッドのサマリー
コンストラクターの詳細
CompositeProducerInterceptor
@SafeVarargsSE public CompositeProducerInterceptor(org.apache.kafka.clients.producer.ProducerInterceptor<K, V>... delegates) 提供されたProducerInterceptor
へのデリゲートを使用してインスタンスを構築します。- パラメーター:
delegates
- 代表団。
メソッドの詳細
onSend
onAcknowledgement
public void onAcknowledgement(org.apache.kafka.clients.producer.RecordMetadata metadata, ExceptionSE exception) close
public void close()- 次で指定:
- インターフェース
AutoCloseableSE
のclose
- 次で指定:
- インターフェース
CloseableSE
のclose
- 次で指定:
- インターフェース
org.apache.kafka.clients.producer.ProducerInterceptor<K,
のV> close
configure
- 次で指定:
- インターフェース
org.apache.kafka.common.Configurable
のconfigure