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

インターフェース PulsarConsumerFactory<T>

型パラメーター:
T - コンシューマーのペイロード型。
すべての既知の実装クラス:
DefaultPulsarConsumerFactory
public interface PulsarConsumerFactory<T>
Pulsar コンシューマーファクトリインターフェース。
作成者:
Soby Chacko, Christophe Bornet, Chris Bono

  • メソッドの詳細

    • createConsumer

      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
      コンシューマーを作成します。
      パラメーター:
      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

      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
      コンシューマーを作成します。
      パラメーター:
      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 - エラーが発生した場合