Class ConsumerConfigProperties

java.lang.Object
org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer
org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties
Direct Known Subclasses:
PulsarConsumerProperties
public class ConsumerConfigProperties extends PulsarProperties.Consumer
Configuration properties used to specify Pulsar consumers.
Author:
Chris Bono

  • Constructor Details

    • ConsumerConfigProperties

      public ConsumerConfigProperties()

  • Method Details

    • getAck

      public ConsumerConfigProperties.Acknowledgement getAck()

    • getChunk

      public ConsumerConfigProperties.Chunking getChunk()

    • getSubscription

      public ConsumerConfigProperties.Subscription getSubscription()
      Overrides:
      getSubscription in class PulsarProperties.Consumer

    • getReceiverQueueSize

      public Integer getReceiverQueueSize()

    • setReceiverQueueSize

      public void setReceiverQueueSize(Integer receiverQueueSize)

    • getMaxTotalReceiverQueueSizeAcrossPartitions

      public Integer getMaxTotalReceiverQueueSizeAcrossPartitions()

    • setMaxTotalReceiverQueueSizeAcrossPartitions

      public void setMaxTotalReceiverQueueSizeAcrossPartitions(Integer maxTotalReceiverQueueSizeAcrossPartitions)

    • getCryptoFailureAction

      public org.apache.pulsar.client.api.ConsumerCryptoFailureAction getCryptoFailureAction()

    • setCryptoFailureAction

      public void setCryptoFailureAction(org.apache.pulsar.client.api.ConsumerCryptoFailureAction cryptoFailureAction)

    • getProperties

      public SortedMap<String,String> getProperties()

    • setProperties

      public void setProperties(SortedMap<String,String> properties)

    • getPatternAutoDiscoveryPeriod

      public Integer getPatternAutoDiscoveryPeriod()

    • setPatternAutoDiscoveryPeriod

      public void setPatternAutoDiscoveryPeriod(Integer patternAutoDiscoveryPeriod)

    • getAutoUpdatePartitions

      public Boolean getAutoUpdatePartitions()

    • setAutoUpdatePartitions

      public void setAutoUpdatePartitions(Boolean autoUpdatePartitions)

    • getAutoUpdatePartitionsInterval

      public Duration getAutoUpdatePartitionsInterval()

    • setAutoUpdatePartitionsInterval

      public void setAutoUpdatePartitionsInterval(Duration autoUpdatePartitionsInterval)

    • getResetIncludeHead

      public Boolean getResetIncludeHead()

    • setResetIncludeHead

      public void setResetIncludeHead(Boolean resetIncludeHead)

    • getPoolMessages

      public Boolean getPoolMessages()

    • setPoolMessages

      public void setPoolMessages(Boolean poolMessages)

    • getStartPaused

      public Boolean getStartPaused()

    • setStartPaused

      public void setStartPaused(Boolean startPaused)

    • toBaseConsumerPropertiesMap

      public Map<String,Object> toBaseConsumerPropertiesMap()
      Gets a map representation of the base consumer properties (those defined in parent class).
      Returns:
      map of base consumer properties and associated values.

    • toExtendedConsumerPropertiesMap

      public Map<String,Object> toExtendedConsumerPropertiesMap()
      Gets a map representation of the extended consumer properties (those defined in this class).
      Returns:
      map of extended consumer properties and associated values.

    • toAllConsumerPropertiesMap

      public Map<String,Object> toAllConsumerPropertiesMap()
      Gets a map representation of base and extended consumer properties.
      Returns:
      map of base and extended consumer properties and associated values.