Class ProducerConfigProperties
java.lang.Object
org.springframework.pulsar.autoconfigure.ProducerConfigProperties
- Direct Known Subclasses:
PulsarProducerProperties
Configuration properties used to specify Pulsar producers.
- Author:
- Chris Bono
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptiongetCache()
org.apache.pulsar.client.api.CompressionType
org.apache.pulsar.client.api.ProducerCryptoFailureAction
org.apache.pulsar.client.api.HashingScheme
org.apache.pulsar.client.api.MessageRoutingMode
org.apache.pulsar.client.api.ProducerAccessMode
void
setAutoUpdatePartitions
(Boolean autoUpdatePartitions) void
setAutoUpdatePartitionsInterval
(Duration autoUpdatePartitionsInterval) void
setBatchingEnabled
(Boolean batchingEnabled) void
setBatchingMaxBytes
(DataSize batchingMaxBytes) void
setBatchingMaxMessages
(Integer batchingMaxMessages) void
setBatchingMaxPublishDelay
(Duration batchingMaxPublishDelay) void
setBatchingPartitionSwitchFrequencyByPublishDelay
(Integer batchingPartitionSwitchFrequencyByPublishDelay) void
setBlockIfQueueFull
(Boolean blockIfQueueFull) void
setChunkingEnabled
(Boolean chunkingEnabled) void
setCompressionType
(org.apache.pulsar.client.api.CompressionType compressionType) void
setCryptoFailureAction
(org.apache.pulsar.client.api.ProducerCryptoFailureAction cryptoFailureAction) void
setEncryptionKeys
(Set<String> encryptionKeys) void
setHashingScheme
(org.apache.pulsar.client.api.HashingScheme hashingScheme) void
setInitialSequenceId
(Long initialSequenceId) void
setLazyStartPartitionedProducers
(Boolean lazyStartPartitionedProducers) void
setMaxPendingMessages
(Integer maxPendingMessages) void
setMaxPendingMessagesAcrossPartitions
(Integer maxPendingMessagesAcrossPartitions) void
setMessageRoutingMode
(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) void
setMultiSchema
(Boolean multiSchema) void
setProducerAccessMode
(org.apache.pulsar.client.api.ProducerAccessMode producerAccessMode) void
setProducerName
(String producerName) void
setProperties
(Map<String, String> properties) void
setSendTimeout
(Duration sendTimeout) void
setTopicName
(String topicName)
-
Constructor Details
-
ProducerConfigProperties
public ProducerConfigProperties()
-
-
Method Details
-
getTopicName
-
setTopicName
-
getProducerName
-
setProducerName
-
getSendTimeout
-
setSendTimeout
-
getBlockIfQueueFull
-
setBlockIfQueueFull
-
getMaxPendingMessages
-
setMaxPendingMessages
-
getMaxPendingMessagesAcrossPartitions
-
setMaxPendingMessagesAcrossPartitions
-
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
-
setBatchingMaxPublishDelay
-
getBatchingPartitionSwitchFrequencyByPublishDelay
-
setBatchingPartitionSwitchFrequencyByPublishDelay
public void setBatchingPartitionSwitchFrequencyByPublishDelay(Integer batchingPartitionSwitchFrequencyByPublishDelay) -
getBatchingMaxMessages
-
setBatchingMaxMessages
-
getBatchingMaxBytes
-
setBatchingMaxBytes
-
getBatchingEnabled
-
setBatchingEnabled
-
getChunkingEnabled
-
setChunkingEnabled
-
getEncryptionKeys
-
setEncryptionKeys
-
getCompressionType
public org.apache.pulsar.client.api.CompressionType getCompressionType() -
setCompressionType
public void setCompressionType(org.apache.pulsar.client.api.CompressionType compressionType) -
getInitialSequenceId
-
setInitialSequenceId
-
getAutoUpdatePartitions
-
setAutoUpdatePartitions
-
getAutoUpdatePartitionsInterval
-
setAutoUpdatePartitionsInterval
-
getMultiSchema
-
setMultiSchema
-
getProducerAccessMode
public org.apache.pulsar.client.api.ProducerAccessMode getProducerAccessMode() -
setProducerAccessMode
public void setProducerAccessMode(org.apache.pulsar.client.api.ProducerAccessMode producerAccessMode) -
getLazyStartPartitionedProducers
-
setLazyStartPartitionedProducers
-
getProperties
-
setProperties
-
getCache
-
toProducerBuilderCustomizer
-