インターフェース 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
新しいコンシューマーが作成されました。- パラメーター:
id
- コンシューマー ID(ピリオドで区切られたファクトリ Bean 名と client.id)。consumer
- コンシューマー。
consumerRemoved
既存のコンシューマーが削除されました。- パラメーター:
id
- コンシューマー ID(ピリオドで区切られたファクトリ Bean 名と client.id)。consumer
- コンシューマー。