インターフェース ShareConsumerFactory<K,V>

型パラメーター:
K - 鍵の型。
V - 値の型。
すべての既知の実装クラス:
DefaultShareConsumerFactory
public interface ShareConsumerFactory<K,V>
Kafka キューサポート用の ShareConsumer インスタンスを生成する戦略。
導入:
4.0
作成者:
Soby Chacko

  • ネストされたクラスの概要

    ネストされたクラス
    修飾子と型
    インターフェース
    説明
    static interface
    ShareConsumerFactory.Listener<K,V>
    共有コンシューマーライフサイクルイベントのリスナー。

  • 方法の概要

    修飾子と型
    メソッド
    説明
    default void
    addListener(int index, ShareConsumerFactory.Listener<K,V> listener)
    特定のインデックスにリスナーを追加します。
    default void
    addListener(ShareConsumerFactory.Listener<K,V> listener)
    リスナーを追加します。
    org.apache.kafka.clients.consumer.ShareConsumer<K,V>
    createShareConsumer(@Nullable StringSE groupId, @Nullable StringSE clientId)
    提供されたグループ ID とクライアント ID を使用して共有コンシューマーを作成します。
    default org.apache.kafka.clients.consumer.ShareConsumer<K,V>
    createShareConsumer(@Nullable StringSE groupId, @Nullable StringSE clientId, MapSE<StringSE,ObjectSE> overrideProperties)
    指定されたグループ ID、クライアント ID、ファクトリの設定を上書きする追加プロパティを使用して、共有コンシューマーを作成します。
    default MapSE<StringSE,ObjectSE>
    getConfigurationProperties()
    このファクトリの構成マップへの変更不可能な参照を返します。
    default @Nullable org.apache.kafka.common.serialization.Deserializer<K>
    getKeyDeserializer()
    構成されたキーデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
    default ListSE<ShareConsumerFactory.Listener<K,V>>
    getListeners()
    リスナーの現在のリストを取得します。
    default @Nullable org.apache.kafka.common.serialization.Deserializer<V>
    getValueDeserializer()
    構成された値のデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
    default boolean
    removeListener(ShareConsumerFactory.Listener<K,V> listener)
    リスナーを削除します。

  • 方法の詳細

    • createShareConsumer

      org.apache.kafka.clients.consumer.ShareConsumer<K,V> createShareConsumer(@Nullable StringSE groupId, @Nullable StringSE clientId)
      提供されたグループ ID とクライアント ID を使用して共有コンシューマーを作成します。
      パラメーター:
      groupId - グループ ID (null の場合もあります)。
      clientId - クライアント ID。
      戻り値:
      シェアコンシューマー。

    • createShareConsumer

      default org.apache.kafka.clients.consumer.ShareConsumer<K,V> createShareConsumer(@Nullable StringSE groupId, @Nullable StringSE clientId, MapSE<StringSE,ObjectSE> overrideProperties)
      指定されたグループ ID、クライアント ID、ファクトリの設定を上書きする追加プロパティを使用して、共有コンシューマーを作成します。コンテナーはこれを使用して、ファクトリの設定を変更することなく、内部設定（確認応答モードなど）を適用します。このメソッドを上書きしない実装は createShareConsumer(String, String) にフォールバックし、上書きプロパティは無視されます。
      パラメーター:
      groupId - グループ ID (null の場合もあります)。
      clientId - クライアント ID（null の場合もある）。
      overrideProperties - 提供時の設定に加えて適用するプロパティ。
      戻り値:
      シェアコンシューマー。
      導入:
      4.1

    • getConfigurationProperties

      default MapSE<StringSE,ObjectSE> getConfigurationProperties()
      このファクトリの構成マップへの変更不可能な参照を返します。類似のファクトリを作るためのクローン作成に便利です。
      戻り値:
      構成。

    • getKeyDeserializer

      default @Nullable org.apache.kafka.common.serialization.Deserializer<K> getKeyDeserializer()
      構成されたキーデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
      戻り値:
      デシリアライザー。

    • getValueDeserializer

      default @Nullable org.apache.kafka.common.serialization.Deserializer<V> getValueDeserializer()
      構成された値のデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
      戻り値:
      デシリアライザー。

    • removeListener

      default boolean removeListener(ShareConsumerFactory.Listener<K,V> listener)
      リスナーを削除します。
      パラメーター:
      listener - リスナー。
      戻り値:
      削除された場合は true。

    • addListener

      default void addListener(int index, ShareConsumerFactory.Listener<K,V> listener)
      特定のインデックスにリスナーを追加します。
      パラメーター:
      index - インデックス (リストの位置)。
      listener - リスナー。

    • addListener

      default void addListener(ShareConsumerFactory.Listener<K,V> listener)
      リスナーを追加します。
      パラメーター:
      listener - リスナー。

    • getListeners

      default ListSE<ShareConsumerFactory.Listener<K,V>> getListeners()
      リスナーの現在のリストを取得します。
      戻り値:
      リスナー。