Class ProducerConfigProperties

java.lang.Object
org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer
org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties
Direct Known Subclasses:
PulsarProducerProperties
public class ProducerConfigProperties extends PulsarProperties.Producer
Configuration properties used to specify Pulsar producers.
Author:
Chris Bono

  • Constructor Details

    • ProducerConfigProperties

      public ProducerConfigProperties()

  • Method Details

    • getBatch

      public ProducerConfigProperties.Batching getBatch()

    • getBlockIfQueueFull

      public Boolean getBlockIfQueueFull()

    • setBlockIfQueueFull

      public void setBlockIfQueueFull(Boolean blockIfQueueFull)

    • getMaxPendingMessages

      public Integer getMaxPendingMessages()

    • setMaxPendingMessages

      public void setMaxPendingMessages(Integer maxPendingMessages)

    • getMaxPendingMessagesAcrossPartitions

      public Integer getMaxPendingMessagesAcrossPartitions()

    • setMaxPendingMessagesAcrossPartitions

      public void setMaxPendingMessagesAcrossPartitions(Integer maxPendingMessagesAcrossPartitions)

    • getCryptoFailureAction

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

    • setCryptoFailureAction

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

    • getEncryptionKeys

      public Set<String> getEncryptionKeys()

    • setEncryptionKeys

      public void setEncryptionKeys(Set<String> encryptionKeys)

    • getInitialSequenceId

      public @Nullable Long getInitialSequenceId()

    • setInitialSequenceId

      public void setInitialSequenceId(@Nullable Long initialSequenceId)

    • getAutoUpdatePartitions

      public Boolean getAutoUpdatePartitions()

    • setAutoUpdatePartitions

      public void setAutoUpdatePartitions(Boolean autoUpdatePartitions)

    • getAutoUpdatePartitionsInterval

      public Duration getAutoUpdatePartitionsInterval()

    • setAutoUpdatePartitionsInterval

      public void setAutoUpdatePartitionsInterval(Duration autoUpdatePartitionsInterval)

    • getMultiSchema

      public Boolean getMultiSchema()

    • setMultiSchema

      public void setMultiSchema(Boolean multiSchema)

    • getLazyStartPartitionedProducers

      public Boolean getLazyStartPartitionedProducers()

    • setLazyStartPartitionedProducers

      public void setLazyStartPartitionedProducers(Boolean lazyStartPartitionedProducers)

    • getProperties

      public Map<String,String> getProperties()

    • setProperties

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

    • toBaseProducerPropertiesMap

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

    • toExtendedProducerPropertiesMap

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

    • toAllProducerPropertiesMap

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