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

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

型パラメーター:
T - プロデューサーのペイロード型
すべての既知の実装クラス:
CachingPulsarProducerFactory, DefaultPulsarProducerFactory
public interface PulsarProducerFactory<T>
Producer インスタンスを作成する戦略。
作成者:
Soby Chacko, Chris Bono, Alexander Preu ß , Christophe Bornet

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    org.apache.pulsar.client.api.Producer<T>
    createProducer(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic)
    プロデューサーを作成します。
    org.apache.pulsar.client.api.Producer<T>
    createProducer(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, CollectionSE<StringSE> encryptionKeys, ListSE<ProducerBuilderCustomizer<T>> customizers)
    プロデューサーを作成します。
    org.apache.pulsar.client.api.Producer<T>
    createProducer(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, ProducerBuilderCustomizer<T> customizer)
    プロデューサーを作成します。
    StringSE
    getDefaultTopic()
    作成されたすべてのプロデューサーに使用するデフォルトのトピックを取得します。

  • メソッドの詳細

    • createProducer

      org.apache.pulsar.client.api.Producer<T> createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable StringSE topic) throws org.apache.pulsar.client.api.PulsarClientException
      プロデューサーを作成します。
      パラメーター:
      schema - 送信されるメッセージのスキーマ
      topic - プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用する null 
      戻り値:
      プロデューサー
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • createProducer

      org.apache.pulsar.client.api.Producer<T> createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable StringSE topic, @Nullable ProducerBuilderCustomizer<T> customizer) throws org.apache.pulsar.client.api.PulsarClientException
      プロデューサーを作成します。
      パラメーター:
      schema - 送信されるメッセージのスキーマ
      topic - プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用する null 
      customizer - プロデューサービルダーに適用するオプションのカスタマイザー
      戻り値:
      プロデューサー
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • createProducer

      org.apache.pulsar.client.api.Producer<T> createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable StringSE topic, @Nullable CollectionSE<StringSE> encryptionKeys, @Nullable ListSE<ProducerBuilderCustomizer<T>> customizers) throws org.apache.pulsar.client.api.PulsarClientException
      プロデューサーを作成します。
      パラメーター:
      schema - 送信されるメッセージのスキーマ
      topic - プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用する null 
      encryptionKeys - プロデューサーが使用する暗号化キー。デフォルトの暗号化キーを置き換えるか、null がデフォルトの暗号化キーを使用します。ProducerBuilder には ProducerBuilder.addEncryptionKey(java.lang.String) のみがあり、暗号化キーを置き換えるメソッドがないことに注意してください。
      customizers - プロデューサービルダーに適用するカスタマイザーのオプションのリスト
      戻り値:
      プロデューサー
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • getDefaultTopic

      @Nullable StringSE getDefaultTopic()
      作成されたすべてのプロデューサーに使用するデフォルトのトピックを取得します。
      戻り値:
      作成されたすべてのプロデューサーに使用するデフォルトのトピック、またはデフォルトが設定されていない場合は null