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

クラス CompositeProducerListener<K,V>

java.lang.ObjectSE
org.springframework.kafka.support.CompositeProducerListener<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装されたすべてのインターフェース:
ProducerListener<K,V>
public class CompositeProducerListener<K,V> extends ObjectSE implements ProducerListener<K,V>
リスナーのコレクションに委譲する ProducerListener。
導入:
2.1.6
作成者:
Gary Russell, Artem Bilan

  • コンストラクターの詳細

  • メソッドの詳細

    • setDelegates

      @SafeVarargsSE public final void setDelegates(ProducerListener<K,V>... delegates)

    • getDelegates

      protected ListSE<ProducerListener<K,V>> getDelegates()

    • addDelegate

      public void addDelegate(ProducerListener<K,V> delegate)

    • removeDelegate

      public boolean removeDelegate(ProducerListener<K,V> delegate)

    • onSuccess

      public void onSuccess(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, org.apache.kafka.clients.producer.RecordMetadata recordMetadata)
      インターフェースからコピーされた説明: ProducerListener
      メッセージの送信が成功した後 (つまり、ブローカーによって確認された後) に呼び出されます。
      次で指定:
      インターフェース ProducerListener<K,V> の onSuccess 
      パラメーター:
      producerRecord - 実際に送信されたレコード
      recordMetadata - 送信操作が成功した結果

    • onError

      public void onError(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, org.apache.kafka.clients.producer.RecordMetadata recordMetadata, ExceptionSE exception)
      インターフェースからコピーされた説明: ProducerListener
      メッセージの送信に失敗した後に呼び出されます。
      次で指定:
      インターフェース ProducerListener<K,V> の onError 
      パラメーター:
      producerRecord - 失敗した記録
      recordMetadata - 送信されたレコードのメタデータ（つまり、パーティションとオフセット）。エラーが発生した場合、メタデータには有効なトピックとおそらくパーティションのみが含まれます。パーティションが ProducerRecord で提供されておらず、パーティションが割り当てられる前にエラーが発生した場合、パーティションは RecordMetadata.UNKNOWN_PARTITION に設定されます。
      exception - スローされた例外