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