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

クラス DefaultPulsarReaderFactory<T>

java.lang.ObjectSE
org.springframework.pulsar.core.DefaultPulsarReaderFactory<T>
型パラメーター:
T - メッセージ型
実装されたすべてのインターフェース:
PulsarReaderFactory<T>
public class DefaultPulsarReaderFactory<T> extends ObjectSE implements PulsarReaderFactory<T>
PulsarReaderFactory のデフォルト実装。
作成者:
Soby Chacko

  • コンストラクターのサマリー

    コンストラクター
    コンストラクター
    説明
    DefaultPulsarReaderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)
    デフォルト設定を持たないリーダーファクトリインスタンスを構築します。
    DefaultPulsarReaderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, ListSE<ReaderBuilderCustomizer<T>> defaultConfigCustomizers)
    リーダーファクトリインスタンスを構築します。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    org.apache.pulsar.client.api.Reader<T>
    createReader(ListSE<StringSE> topics, org.apache.pulsar.client.api.MessageId messageId, org.apache.pulsar.client.api.Schema<T> schema, ListSE<ReaderBuilderCustomizer<T>> customizers)
    提供されたトピック、スキーマ、プロパティに基づいて Pulsar Reader を作成します。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

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

    • DefaultPulsarReaderFactory

      public DefaultPulsarReaderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)
      デフォルト設定を持たないリーダーファクトリインスタンスを構築します。
      パラメーター:
      pulsarClient - クライアントが消費していた

    • DefaultPulsarReaderFactory

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

  • メソッドの詳細

    • createReader

      public org.apache.pulsar.client.api.Reader<T> createReader(@Nullable ListSE<StringSE> topics, @Nullable org.apache.pulsar.client.api.MessageId messageId, org.apache.pulsar.client.api.Schema<T> schema, @Nullable ListSE<ReaderBuilderCustomizer<T>> customizers) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarReaderFactory
      提供されたトピック、スキーマ、プロパティに基づいて Pulsar Reader を作成します。
      次で指定:
      インターフェース PulsarReaderFactory<T> の createReader 
      パラメーター:
      topics - 読むトピックのセット
      messageId - 読み取りの開始メッセージ ID
      schema - 消費するメッセージのスキーマ
      customizers - Reader Builder に適用するカスタマイザーのオプションのリスト。カスタマイザは最後に適用され、指定されたパラメーターやデフォルトのプロパティをオーバーライドする可能性があることに注意してください。
      戻り値:
      Pulsar Reader
      例外:
      org.apache.pulsar.client.api.PulsarClientException - リーダーの作成時に問題が発生した場合