インターフェース PulsarConsumerFactory<T>
- 型パラメーター:
T
- コンシューマーのペイロード型。
- すべての既知の実装クラス:
DefaultPulsarConsumerFactory
public interface PulsarConsumerFactory<T>
Pulsar コンシューマーファクトリインターフェース。
- 作成者:
- Soby Chacko, Christophe Bornet, Chris Bono, Jonas Geiregat
メソッドのサマリー
修飾子と型メソッド説明org.apache.pulsar.client.api.Consumer<T>
createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, CollectionSE<StringSE> topics, StringSE subscriptionName, MapSE<StringSE, StringSE> metadataProperties, ListSE<ConsumerBuilderCustomizer<T>> customizers) コンシューマーを作成します。org.apache.pulsar.client.api.Consumer<T>
createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, CollectionSE<StringSE> topics, StringSE subscriptionName, ConsumerBuilderCustomizer<T> customizer) コンシューマーを作成します。
メソッドの詳細
createConsumer
org.apache.pulsar.client.api.Consumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable CollectionSE<StringSE> topics, @Nullable StringSE subscriptionName, ConsumerBuilderCustomizer<T> customizer) コンシューマーを作成します。- パラメーター:
schema
- 送信されるメッセージのスキーマtopics
- コンシューマーがサブスクライブするトピック、デフォルトのトピックを置き換えるか、null
がデフォルトのトピックを使用します。ConsumerBuilder.topic(java.lang.String...)
またはConsumerBuilder.topics(java.util.List<java.lang.String>)
を使用すると、デフォルトのトピックが上書きされるのではなく、追加されることに注意してください。また、デフォルトのトピックが設定されていないときにnull
を指定すると例外が発生することに注意してください。subscriptionName
- 消費されたトピックへのサブスクリプションに使用する名前、またはデフォルトの構成済みサブスクリプション名を使用するnull
。デフォルトのサブスクリプション名が構成されていない場合にnull
を指定すると、例外が発生することに注意してください。customizer
- Consumer Builder に適用するオプションのカスタマイザー。カスタマイザは最後に適用され、指定されたパラメーターやデフォルトのプロパティをオーバーライドする可能性があることに注意してください。- 戻り値:
- コンシューマー
- 例外:
PulsarException
- Pulsar との通信中にPulsarClientException
が発生した場合
createConsumer
org.apache.pulsar.client.api.Consumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable CollectionSE<StringSE> topics, @Nullable StringSE subscriptionName, @Nullable MapSE<StringSE, StringSE> metadataProperties, @Nullable ListSE<ConsumerBuilderCustomizer<T>> customizers) コンシューマーを作成します。- パラメーター:
schema
- 送信されるメッセージのスキーマtopics
- コンシューマーがサブスクライブするトピック、デフォルトのトピックを置き換えるか、null
がデフォルトのトピックを使用します。ConsumerBuilder.topic(java.lang.String...)
またはConsumerBuilder.topics(java.util.List<java.lang.String>)
を使用すると、デフォルトのトピックが上書きされるのではなく、追加されることに注意してください。また、デフォルトのトピックが設定されていないときにnull
を指定すると例外が発生することに注意してください。subscriptionName
- 消費されたトピックへのサブスクリプションに使用する名前、またはデフォルトの構成済みサブスクリプション名を使用するnull
。デフォルトのサブスクリプション名が構成されていない場合にnull
を指定すると、例外が発生することに注意してください。metadataProperties
- デフォルトのメタデータプロパティを置き換えてコンシューマーに添付するメタデータプロパティ、またはデフォルトのメタデータプロパティを使用するnull
。ConsumerBuilder.property(java.lang.String, java.lang.String)
またはConsumerBuilder.properties(java.util.Map<java.lang.String, java.lang.String>)
を使用すると、デフォルトのメタデータプロパティが置き換えられるのではなく、追加されることに注意してください。customizers
- Consumer Builder に適用するカスタマイザーのオプションのリスト。カスタマイザは最後に適用され、指定されたパラメーターやデフォルトのプロパティをオーバーライドする可能性があることに注意してください。- 戻り値:
- コンシューマー
- 例外:
PulsarException
- Pulsar との通信中にPulsarClientException
が発生した場合