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

クラス DefaultPulsarConsumerFactory<T>

java.lang.ObjectSE
org.springframework.pulsar.core.DefaultPulsarConsumerFactory<T>
型パラメーター:
T - コンシューマーの基礎となるペイロード型。
実装されたすべてのインターフェース:
PulsarConsumerFactory<T>
public class DefaultPulsarConsumerFactory<T> extends ObjectSE implements PulsarConsumerFactory<T>
PulsarConsumerFactory のデフォルト実装。
作成者:
Soby Chacko, Alexander Preu ß , Christophe Bornet, Chris Bono

  • コンストラクターの詳細

    • DefaultPulsarConsumerFactory

      public DefaultPulsarConsumerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, ListSE<ConsumerBuilderCustomizer<T>> defaultConfigCustomizers)
      コンシューマーファクトリインスタンスを構築します。
      パラメーター:
      pulsarClient - クライアントが消費していた
      defaultConfigCustomizers - 作成されたコンシューマーに適用するカスタマイザーのオプションのリスト、またはデフォルト構成を使用しない場合は null

  • メソッドの詳細

    • createConsumer

      public org.apache.pulsar.client.api.Consumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable CollectionSE<StringSE> topics, @Nullable StringSE subscriptionName, ConsumerBuilderCustomizer<T> customizer) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarConsumerFactory
      コンシューマーを作成します。
      次で指定:
      インターフェース PulsarConsumerFactory<T> の createConsumer 
      パラメーター:
      schema - 送信されるメッセージのスキーマ
      topics - コンシューマーがサブスクライブするトピック、デフォルトのトピックを置き換えるか、null がデフォルトのトピックを使用します。ConsumerBuilder.topic(java.lang.String...) または ConsumerBuilder.topics(java.util.List<java.lang.String>) を使用すると、デフォルトのトピックが上書きされるのではなく、追加されることに注意してください。また、デフォルトのトピックが設定されていないときに null を指定すると例外が発生することに注意してください。
      subscriptionName - 消費されたトピックへのサブスクリプションに使用する名前、またはデフォルトの構成済みサブスクリプション名を使用する null。デフォルトのサブスクリプション名が構成されていない場合に null を指定すると、例外が発生することに注意してください。
      customizer - Consumer Builder に適用するオプションのカスタマイザー。カスタマイザは最後に適用され、指定されたパラメーターやデフォルトのプロパティをオーバーライドする可能性があることに注意してください。
      戻り値:
      コンシューマー
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • createConsumer

      public org.apache.pulsar.client.api.Consumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable CollectionSE<StringSE> topics, @Nullable StringSE subscriptionName, @Nullable MapSE<StringSE,StringSE> metadataProperties, @Nullable ListSE<ConsumerBuilderCustomizer<T>> customizers) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarConsumerFactory
      コンシューマーを作成します。
      次で指定:
      インターフェース PulsarConsumerFactory<T> の createConsumer 
      パラメーター:
      schema - 送信されるメッセージのスキーマ
      topics - コンシューマーがサブスクライブするトピック、デフォルトのトピックを置き換えるか、null がデフォルトのトピックを使用します。ConsumerBuilder.topic(java.lang.String...) または ConsumerBuilder.topics(java.util.List<java.lang.String>) を使用すると、デフォルトのトピックが上書きされるのではなく、追加されることに注意してください。また、デフォルトのトピックが設定されていないときに null を指定すると例外が発生することに注意してください。
      subscriptionName - 消費されたトピックへのサブスクリプションに使用する名前、またはデフォルトの構成済みサブスクリプション名を使用する null。デフォルトのサブスクリプション名が構成されていない場合に null を指定すると、例外が発生することに注意してください。
      metadataProperties - デフォルトのメタデータプロパティを置き換えてコンシューマーに添付するメタデータプロパティ、またはデフォルトのメタデータプロパティを使用する null。ConsumerBuilder.property(java.lang.String, java.lang.String) または ConsumerBuilder.properties(java.util.Map<java.lang.String, java.lang.String>) を使用すると、デフォルトのメタデータプロパティが置き換えられるのではなく、追加されることに注意してください。
      customizers - Consumer Builder に適用するカスタマイザーのオプションのリスト。カスタマイザは最後に適用され、指定されたパラメーターやデフォルトのプロパティをオーバーライドする可能性があることに注意してください。
      戻り値:
      コンシューマー
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合