インターフェース GenericMessageListener<T>

型パラメーター:
T - リスナーが受信した型。
すべての既知のサブインターフェース:
AcknowledgingConsumerAwareMessageListener<K,V>AcknowledgingMessageListener<K,V>BatchAcknowledgingConsumerAwareMessageListener<K,V>BatchAcknowledgingMessageListener<K,V>BatchConsumerAwareMessageListener<K,V>BatchMessageListener<K,V>ConsumerAwareMessageListener<K,V>MessageListener<K,V>
すべての既知の実装クラス:
AggregatingReplyingKafkaTemplateBatchMessagingMessageListenerAdapterConvertingMessageListenerFilteringBatchMessageListenerAdapterFilteringMessageListenerAdapterKafkaBackoffAwareMessageListenerAdapterRecordMessagingMessageListenerAdapterReplyingKafkaTemplate
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。

@FunctionalInterfaceSE public interface GenericMessageListener<T>
リスナーのトップレベルインターフェース。
導入:
1.1
作成者:
Gary Russell
  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    onMessage(T data)
    kafka からのデータで呼び出されます。
    default void
    onMessage(T data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
    kafka からのデータで呼び出され、Consumer へのアクセスを提供します。
    default void
    onMessage(T data, Acknowledgment acknowledgment)
    kafka からのデータで呼び出されます。
    default void
    onMessage(T data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
    kafka からのデータで呼び出され、Consumer へのアクセスを提供します。
  • メソッドの詳細

    • onMessage

      void onMessage(T data)
      kafka からのデータで呼び出されます。
      パラメーター:
      data - 処理されるデータ。
    • onMessage

      default void onMessage(T data, @Nullable Acknowledgment acknowledgment)
      kafka からのデータで呼び出されます。デフォルトの実装は UnsupportedOperationExceptionSE をスローします。
      パラメーター:
      data - 処理されるデータ。
      acknowledgment - 承認。
    • onMessage

      default void onMessage(T data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      kafka からのデータで呼び出され、Consumer へのアクセスを提供します。デフォルトの実装は UnsupportedOperationExceptionSE をスローします。
      パラメーター:
      data - 処理されるデータ。
      consumer - コンシューマー。
      導入:
      2.0
    • onMessage

      default void onMessage(T data, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      kafka からのデータで呼び出され、Consumer へのアクセスを提供します。デフォルトの実装は UnsupportedOperationExceptionSE をスローします。
      パラメーター:
      data - 処理されるデータ。
      acknowledgment - 承認。
      consumer - コンシューマー。
      導入:
      2.0