クラス DefaultShareConsumerFactory<K,V>

方法の詳細

• createShareConsumer

  public org.apache.kafka.clients.consumer.ShareConsumer<K,V> createShareConsumer(@Nullable StringSE groupId, @Nullable StringSE clientId)

  提供されたグループ ID とクライアント ID を使用して共有コンシューマーを作成します。

  次で指定:

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

  パラメーター:

  groupId - グループ ID (null の場合もあります)。

  clientId - クライアント ID。

  戻り値:

  シェアコンシューマー。

• createShareConsumer

  public org.apache.kafka.clients.consumer.ShareConsumer<K,V> createShareConsumer(@Nullable StringSE groupId, @Nullable StringSE clientId, MapSE<StringSE,ObjectSE> overrideProperties)

  インターフェースからコピーされた説明: ShareConsumerFactory

  指定されたグループ ID、クライアント ID、ファクトリの設定を上書きする追加プロパティを使用して、共有コンシューマーを作成します。コンテナーはこれを使用して、ファクトリの設定を変更することなく、内部設定（確認応答モードなど）を適用します。このメソッドを上書きしない実装は ShareConsumerFactory.createShareConsumer(String, String) にフォールバックし、上書きプロパティは無視されます。

  次で指定:

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

  パラメーター:

  groupId - グループ ID (null の場合もあります)。

  clientId - クライアント ID（null の場合もある）。

  overrideProperties - 提供時の設定に加えて適用するプロパティ。

  戻り値:

  シェアコンシューマー。

• createRawConsumer

  protected org.apache.kafka.clients.consumer.ShareConsumer<K,V> createRawConsumer(@Nullable StringSE groupId, @Nullable StringSE clientId)

  Create the consumer with no override properties. Subclasses may override to customize consumer creation.

  パラメーター:

  groupId - グループ ID (null の場合もあります)。

  clientId - クライアント ID（null の場合もある）。

  戻り値:

  シェアコンシューマー。

• createRawConsumer

  protected org.apache.kafka.clients.consumer.ShareConsumer<K,V> createRawConsumer(@Nullable StringSE groupId, @Nullable StringSE clientId, MapSE<StringSE,ObjectSE> overrideProperties)

  Actually create the consumer, applying override properties on top of the factory configuration. Override properties take precedence over factory configuration; groupId and clientId are applied last.

  パラメーター:

  groupId - グループ ID (null の場合もあります)。

  clientId - クライアント ID（null の場合もある）。

  overrideProperties - 提供時の設定に加えて適用するプロパティ。

  戻り値:

  シェアコンシューマー。

  導入:

  4.1

• setBeanName

  public void setBeanName(StringSE name)

  次で指定:

  インターフェース BeanNameAware 内の setBeanName 

• setKeyDeserializer

  public void setKeyDeserializer(@Nullable org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer)

  キーデシリアライザーを設定します。デシリアライザーは、configureDeserializers が false でない限り、コンシューマー構成を使用して構成されます。

  パラメーター:

  keyDeserializer - デシリアライザー。

• setValueDeserializer

  public void setValueDeserializer(@Nullable org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)

  デシリアライザーの値を設定します。デシリアライザーは、configureDeserializers が false でない限り、コンシューマー構成を使用して構成されます。

  パラメーター:

  valueDeserializer - 値デシリアライザー。

• getKeyDeserializer

  public @Nullable org.apache.kafka.common.serialization.Deserializer<K> getKeyDeserializer()

  インターフェースからコピーされた説明: ShareConsumerFactory

  構成されたキーデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。

  次で指定:

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

  戻り値:

  デシリアライザー。

• getValueDeserializer

  public @Nullable org.apache.kafka.common.serialization.Deserializer<V> getValueDeserializer()

  インターフェースからコピーされた説明: ShareConsumerFactory

  構成された値のデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。

  次で指定:

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

  戻り値:

  デシリアライザー。

• setKeyDeserializerSupplier

  public void setKeyDeserializerSupplier(@Nullable SupplierSE<@Nullable org.apache.kafka.common.serialization.Deserializer<K>> keyDeserializerSupplier)

  キーデシリアライザーのインスタンスを提供するようにサプライヤーを設定します。デシリアライザーは、configureDeserializers が false でない限り、コンシューマー構成を使用して構成されます。

  パラメーター:

  keyDeserializerSupplier - サプライヤー（null 可能）。

• setValueDeserializerSupplier

  public void setValueDeserializerSupplier(@Nullable SupplierSE<@Nullable org.apache.kafka.common.serialization.Deserializer<V>> valueDeserializerSupplier)

  値デシリアライザーのインスタンスを提供するようにサプライヤーを設定します。デシリアライザーは、configureDeserializers が false でない限り、コンシューマー構成を使用して構成されます。

  パラメーター:

  valueDeserializerSupplier - サプライヤー（null 可能）。

• setConfigureDeserializers

  public void setConfigureDeserializers(boolean configureDeserializers)

  デシリアライザーがすでに完全に構成されている場合など、プログラムで提供されるデシリアライザー (コンストラクターまたは setter 経由) がコンシューマー構成を使用して構成されるのを防ぐには、false (デフォルトは true) に設定します。

  パラメーター:

  configureDeserializers - 構成しない場合は false。

  関連事項:

  • setKeyDeserializer(Deserializer)
  • setKeyDeserializerSupplier(Supplier)
  • setValueDeserializer(Deserializer)
  • setValueDeserializerSupplier(Supplier)

• getListeners

  public ListSE<ShareConsumerFactory.Listener<K,V>> getListeners()

  リスナーの現在のリストを取得します。

  次で指定:

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

  戻り値:

  リスナー。

• addListener

  public void addListener(ShareConsumerFactory.Listener<K,V> listener)

  リスナーを追加します。

  次で指定:

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

  パラメーター:

  listener - リスナー。

• addListener

  public void addListener(int index, ShareConsumerFactory.Listener<K,V> listener)

  特定のインデックスにリスナーを追加します。

  このメソッドを使用すると、内部リスナーリストの特定の位置にリスナーを挿入できます。これにより、リスナーコールバックの順序付けが可能になります（これは特定の監視や拡張シナリオで重要になる場合があります）。ただし、対応する removeListener(int index) 契約は意図的に用意されていません。インデックスによるリスナーの削除は推奨されません。他のリスナーが追加または削除されると、リスナーの位置が変わる可能性があるため、間違ったリスナーを誤って削除してしまう可能性が高くなります。リスナーを参照（オブジェクト）で管理する方が安全で、特にリスナーは通常初期化時に一度だけ設定されるため、エラーが発生しにくくなります。

  次で指定:

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

  パラメーター:

  index - インデックス (リストの位置)。

  listener - 追加するリスナー。

• removeListener

  public boolean removeListener(ShareConsumerFactory.Listener<K,V> listener)

  リスナーを削除します。

  次で指定:

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

  パラメーター:

  listener - リスナー。

  戻り値:

  削除された場合は true。

• getConfigurationProperties

  public MapSE<StringSE,ObjectSE> getConfigurationProperties()

  インターフェースからコピーされた説明: ShareConsumerFactory

  このファクトリの構成マップへの変更不可能な参照を返します。類似のファクトリを作るためのクローン作成に便利です。

  次で指定:

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

  戻り値:

  構成。