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