Class ProducerConfigProperties

java.lang.Object
org.springframework.pulsar.autoconfigure.ProducerConfigProperties
Direct Known Subclasses:
PulsarProducerProperties

public class ProducerConfigProperties extends Object
Configuration properties used to specify Pulsar producers.
Author:
Chris Bono
  • Constructor Details

    • ProducerConfigProperties

      public ProducerConfigProperties()
  • Method Details

    • getTopicName

      public String getTopicName()
    • setTopicName

      public void setTopicName(String topicName)
    • getProducerName

      public String getProducerName()
    • setProducerName

      public void setProducerName(String producerName)
    • getSendTimeout

      public Duration getSendTimeout()
    • setSendTimeout

      public void setSendTimeout(Duration sendTimeout)
    • 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)
    • getMessageRoutingMode

      public org.apache.pulsar.client.api.MessageRoutingMode getMessageRoutingMode()
    • setMessageRoutingMode

      public void setMessageRoutingMode(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode)
    • getHashingScheme

      public org.apache.pulsar.client.api.HashingScheme getHashingScheme()
    • setHashingScheme

      public void setHashingScheme(org.apache.pulsar.client.api.HashingScheme hashingScheme)
    • getCryptoFailureAction

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

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

      public Duration getBatchingMaxPublishDelay()
    • setBatchingMaxPublishDelay

      public void setBatchingMaxPublishDelay(Duration batchingMaxPublishDelay)
    • getBatchingPartitionSwitchFrequencyByPublishDelay

      public Integer getBatchingPartitionSwitchFrequencyByPublishDelay()
    • setBatchingPartitionSwitchFrequencyByPublishDelay

      public void setBatchingPartitionSwitchFrequencyByPublishDelay(Integer batchingPartitionSwitchFrequencyByPublishDelay)
    • getBatchingMaxMessages

      public Integer getBatchingMaxMessages()
    • setBatchingMaxMessages

      public void setBatchingMaxMessages(Integer batchingMaxMessages)
    • getBatchingMaxBytes

      public DataSize getBatchingMaxBytes()
    • setBatchingMaxBytes

      public void setBatchingMaxBytes(DataSize batchingMaxBytes)
    • getBatchingEnabled

      public Boolean getBatchingEnabled()
    • setBatchingEnabled

      public void setBatchingEnabled(Boolean batchingEnabled)
    • getChunkingEnabled

      public Boolean getChunkingEnabled()
    • setChunkingEnabled

      public void setChunkingEnabled(Boolean chunkingEnabled)
    • getEncryptionKeys

      public Set<String> getEncryptionKeys()
    • setEncryptionKeys

      public void setEncryptionKeys(Set<String> encryptionKeys)
    • getCompressionType

      public org.apache.pulsar.client.api.CompressionType getCompressionType()
    • setCompressionType

      public void setCompressionType(org.apache.pulsar.client.api.CompressionType compressionType)
    • getInitialSequenceId

      @Nullable public 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)
    • getProducerAccessMode

      public org.apache.pulsar.client.api.ProducerAccessMode getProducerAccessMode()
    • setProducerAccessMode

      public void setProducerAccessMode(org.apache.pulsar.client.api.ProducerAccessMode producerAccessMode)
    • getLazyStartPartitionedProducers

      public Boolean getLazyStartPartitionedProducers()
    • setLazyStartPartitionedProducers

      public void setLazyStartPartitionedProducers(Boolean lazyStartPartitionedProducers)
    • getProperties

      public Map<String,String> getProperties()
    • setProperties

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

      public PulsarProperties.Cache getCache()
    • toProducerBuilderCustomizer

      public ProducerBuilderCustomizer<?> toProducerBuilderCustomizer()