Class DefaultPulsarConsumerFactory<T>

java.lang.Object
org.springframework.pulsar.core.DefaultPulsarConsumerFactory<T>
Type Parameters:
T - underlying payload type for the consumer.
All Implemented Interfaces:
PulsarConsumerFactory<T>

public class DefaultPulsarConsumerFactory<T> extends Object implements PulsarConsumerFactory<T>
Default implementation for PulsarConsumerFactory.
Author:
Soby Chacko, Alexander Preuß, Christophe Bornet
  • Constructor Details

    • DefaultPulsarConsumerFactory

      public DefaultPulsarConsumerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)
    • DefaultPulsarConsumerFactory

      public DefaultPulsarConsumerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, Map<String,Object> consumerConfig)
  • Method Details

    • createConsumer

      public org.apache.pulsar.client.api.Consumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema) throws org.apache.pulsar.client.api.PulsarClientException
      Description copied from interface: PulsarConsumerFactory
      Create a consumer.
      Specified by:
      createConsumer in interface PulsarConsumerFactory<T>
      Parameters:
      schema - the schema of the messages to be sent
      Returns:
      the consumer
      Throws:
      org.apache.pulsar.client.api.PulsarClientException - if any error occurs
    • createConsumer

      public org.apache.pulsar.client.api.Consumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable Collection<String> topics) throws org.apache.pulsar.client.api.PulsarClientException
      Description copied from interface: PulsarConsumerFactory
      Create a consumer.
      Specified by:
      createConsumer in interface PulsarConsumerFactory<T>
      Parameters:
      schema - the schema of the messages to be sent
      topics - the topics the consumer will subscribe to overriding the default ones or null to use the default topics
      Returns:
      the consumer
      Throws:
      org.apache.pulsar.client.api.PulsarClientException - if any error occurs
    • createConsumer

      public org.apache.pulsar.client.api.Consumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable Collection<String> topics, @Nullable Map<String,String> properties, @Nullable List<ConsumerBuilderCustomizer<T>> customizers) throws org.apache.pulsar.client.api.PulsarClientException
      Description copied from interface: PulsarConsumerFactory
      Create a consumer.
      Specified by:
      createConsumer in interface PulsarConsumerFactory<T>
      Parameters:
      schema - the schema of the messages to be sent
      topics - the topics the consumer will subscribe to overriding the default ones or null to use the default topics. Beware that using ConsumerBuilder.topic(java.lang.String...) or ConsumerBuilder.topics(java.util.List<java.lang.String>) will add to the default topics, not override them.
      properties - the metadata properties to attach to the consumer, replacing the default metadata properties, or null to use the default metadata properties. Beware that using ConsumerBuilder.property(java.lang.String, java.lang.String) or ConsumerBuilder.properties(java.util.Map<java.lang.String, java.lang.String>) will add to the default metadata properties, not replace them.
      customizers - the optional list of customizers to apply to the consumer builder
      Returns:
      the consumer
      Throws:
      org.apache.pulsar.client.api.PulsarClientException - if any error occurs
    • getConsumerConfig

      public Map<String,Object> getConsumerConfig()
      Description copied from interface: PulsarConsumerFactory
      Return the configuration options to use when creating consumers.
      Specified by:
      getConsumerConfig in interface PulsarConsumerFactory<T>
      Returns:
      the configuration options