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

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

型パラメーター:
T - このリーダーによって処理される基になるメッセージ型。
すべての既知の実装クラス:
DefaultPulsarReaderFactory
public interface PulsarReaderFactory<T>
Pulsar Reader 提供時のインターフェース。
作成者:
Soby Chacko

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    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 を作成します。

  • メソッドの詳細

    • createReader

      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
      提供されたトピック、スキーマ、プロパティに基づいて Pulsar Reader を作成します。
      パラメーター:
      topics - 読むトピックのセット
      messageId - 読み取りの開始メッセージ ID
      schema - 消費するメッセージのスキーマ
      customizers - Reader Builder に適用するカスタマイザーのオプションのリスト。カスタマイザは最後に適用され、指定されたパラメーターやデフォルトのプロパティをオーバーライドする可能性があることに注意してください。
      戻り値:
      Pulsar Reader
      例外:
      org.apache.pulsar.client.api.PulsarClientException - リーダーの作成時に問題が発生した場合