パッケージ org.springframework.kafka.support

クラス 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

      @SafeVarargsSE public CompositeProducerInterceptor(org.apache.kafka.clients.producer.ProducerInterceptor<K,V>... delegates)
      提供された ProducerInterceptor へのデリゲートを使用してインスタンスを構築します。
      パラメーター:
      delegates - 代表団。

  • メソッドの詳細

    • onSend

      public org.apache.kafka.clients.producer.ProducerRecord<K,V> onSend(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
      次で指定:
      インターフェース org.apache.kafka.clients.producer.ProducerInterceptor<K,V> の onSend 

    • onAcknowledgement

      public void onAcknowledgement(org.apache.kafka.clients.producer.RecordMetadata metadata, ExceptionSE exception)
      次で指定:
      インターフェース org.apache.kafka.clients.producer.ProducerInterceptor<K,V> の onAcknowledgement 

    • close

      public void close()
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース CloseableSE の close 
      次で指定:
      インターフェース org.apache.kafka.clients.producer.ProducerInterceptor<K,V> の close 

    • configure

      public void configure(MapSE<StringSE,?> configs)
      次で指定:
      インターフェース org.apache.kafka.common.Configurable の configure