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

インターフェース ConsumerFactory.Listener<K,V>

型パラメーター:
K - 鍵の型。
V - 値の型。
すべての既知の実装クラス:
MicrometerConsumerListener
含まれているインターフェース:
ConsumerFactory<K,V>
public static interface ConsumerFactory.Listener<K,V>
コンシューマーが追加または削除されるたびに呼び出されます。
導入:
2.5

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    default void
    consumerAdded(StringSE id, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
    新しいコンシューマーが作成されました。
    default void
    consumerRemoved(StringSE id, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
    既存のコンシューマーが削除されました。

  • メソッドの詳細

    • consumerAdded

      default void consumerAdded(StringSE id, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
      新しいコンシューマーが作成されました。
      パラメーター:
      id - コンシューマー ID（ピリオドで区切られたファクトリ Bean 名と client.id）。
      consumer - コンシューマー。

    • consumerRemoved

      default void consumerRemoved(StringSE id, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
      既存のコンシューマーが削除されました。
      パラメーター:
      id - コンシューマー ID（ピリオドで区切られたファクトリ Bean 名と client.id）。
      consumer - コンシューマー。