Class ConsumerConfigProperties
java.lang.Object
org.springframework.pulsar.autoconfigure.ConsumerConfigProperties
- Direct Known Subclasses:
PulsarConsumerProperties
Configuration properties used to specify Pulsar consumers.
- Author:
- Chris Bono
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.client.api.ConsumerCryptoFailureActionorg.apache.pulsar.client.api.DeadLetterPolicyorg.apache.pulsar.client.api.RegexSubscriptionModeorg.apache.pulsar.client.api.SubscriptionInitialPositionorg.apache.pulsar.client.api.SubscriptionModeorg.apache.pulsar.client.api.SubscriptionTypevoidsetAcknowledgementsGroupTime(Duration acknowledgementsGroupTime) voidsetAckReceiptEnabled(Boolean ackReceiptEnabled) voidsetAckTimeout(Duration ackTimeout) voidsetAutoAckOldestChunkedMessageOnQueueFull(Boolean autoAckOldestChunkedMessageOnQueueFull) voidsetAutoUpdatePartitions(Boolean autoUpdatePartitions) voidsetAutoUpdatePartitionsInterval(Duration autoUpdatePartitionsInterval) voidsetBatchIndexAckEnabled(Boolean batchIndexAckEnabled) voidsetConsumerName(String consumerName) voidsetCryptoFailureAction(org.apache.pulsar.client.api.ConsumerCryptoFailureAction cryptoFailureAction) voidsetDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) voidsetExpireTimeOfIncompleteChunkedMessage(Duration expireTimeOfIncompleteChunkedMessage) voidsetMaxPendingChunkedMessage(Integer maxPendingChunkedMessage) voidsetMaxTotalReceiverQueueSizeAcrossPartitions(Integer maxTotalReceiverQueueSizeAcrossPartitions) voidsetNegativeAckRedeliveryDelay(Duration negativeAckRedeliveryDelay) voidsetPatternAutoDiscoveryPeriod(Integer patternAutoDiscoveryPeriod) voidsetPoolMessages(Boolean poolMessages) voidsetPriorityLevel(Integer priorityLevel) voidsetProperties(SortedMap<String, String> properties) voidsetReadCompacted(Boolean readCompacted) voidsetReceiverQueueSize(Integer receiverQueueSize) voidsetRegexSubscriptionMode(org.apache.pulsar.client.api.RegexSubscriptionMode regexSubscriptionMode) voidsetReplicateSubscriptionState(Boolean replicateSubscriptionState) voidsetResetIncludeHead(Boolean resetIncludeHead) voidsetRetryEnable(Boolean retryEnable) voidsetStartPaused(Boolean startPaused) voidsetSubscriptionInitialPosition(org.apache.pulsar.client.api.SubscriptionInitialPosition subscriptionInitialPosition) voidsetSubscriptionMode(org.apache.pulsar.client.api.SubscriptionMode subscriptionMode) voidsetSubscriptionName(String subscriptionName) voidsetSubscriptionProperties(Map<String, String> subscriptionProperties) voidsetSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType) voidsetTickDuration(Duration tickDuration) voidvoidsetTopicsPattern(Pattern topicsPattern)
-
Constructor Details
-
ConsumerConfigProperties
public ConsumerConfigProperties()
-
-
Method Details
-
getTopics
-
setTopics
-
getTopicsPattern
-
setTopicsPattern
-
getSubscriptionName
-
setSubscriptionName
-
getSubscriptionProperties
-
setSubscriptionProperties
-
getSubscriptionMode
public org.apache.pulsar.client.api.SubscriptionMode getSubscriptionMode() -
setSubscriptionMode
public void setSubscriptionMode(org.apache.pulsar.client.api.SubscriptionMode subscriptionMode) -
getSubscriptionType
public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType() -
setSubscriptionType
public void setSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType) -
getReceiverQueueSize
-
setReceiverQueueSize
-
getAcknowledgementsGroupTime
-
setAcknowledgementsGroupTime
-
getNegativeAckRedeliveryDelay
-
setNegativeAckRedeliveryDelay
-
getMaxTotalReceiverQueueSizeAcrossPartitions
-
setMaxTotalReceiverQueueSizeAcrossPartitions
public void setMaxTotalReceiverQueueSizeAcrossPartitions(Integer maxTotalReceiverQueueSizeAcrossPartitions) -
getConsumerName
-
setConsumerName
-
getAckTimeout
-
setAckTimeout
-
getTickDuration
-
setTickDuration
-
getPriorityLevel
-
setPriorityLevel
-
getCryptoFailureAction
public org.apache.pulsar.client.api.ConsumerCryptoFailureAction getCryptoFailureAction() -
setCryptoFailureAction
public void setCryptoFailureAction(org.apache.pulsar.client.api.ConsumerCryptoFailureAction cryptoFailureAction) -
getProperties
-
setProperties
-
getReadCompacted
-
setReadCompacted
-
getSubscriptionInitialPosition
public org.apache.pulsar.client.api.SubscriptionInitialPosition getSubscriptionInitialPosition() -
setSubscriptionInitialPosition
public void setSubscriptionInitialPosition(org.apache.pulsar.client.api.SubscriptionInitialPosition subscriptionInitialPosition) -
getPatternAutoDiscoveryPeriod
-
setPatternAutoDiscoveryPeriod
-
getRegexSubscriptionMode
public org.apache.pulsar.client.api.RegexSubscriptionMode getRegexSubscriptionMode() -
setRegexSubscriptionMode
public void setRegexSubscriptionMode(org.apache.pulsar.client.api.RegexSubscriptionMode regexSubscriptionMode) -
getDeadLetterPolicy
-
setDeadLetterPolicy
public void setDeadLetterPolicy(@Nullable org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) -
getRetryEnable
-
setRetryEnable
-
getAutoUpdatePartitions
-
setAutoUpdatePartitions
-
getAutoUpdatePartitionsInterval
-
setAutoUpdatePartitionsInterval
-
getReplicateSubscriptionState
-
setReplicateSubscriptionState
-
getResetIncludeHead
-
setResetIncludeHead
-
getBatchIndexAckEnabled
-
setBatchIndexAckEnabled
-
getAckReceiptEnabled
-
setAckReceiptEnabled
-
getPoolMessages
-
setPoolMessages
-
getStartPaused
-
setStartPaused
-
getAutoAckOldestChunkedMessageOnQueueFull
-
setAutoAckOldestChunkedMessageOnQueueFull
public void setAutoAckOldestChunkedMessageOnQueueFull(Boolean autoAckOldestChunkedMessageOnQueueFull) -
getMaxPendingChunkedMessage
-
setMaxPendingChunkedMessage
-
getExpireTimeOfIncompleteChunkedMessage
-
setExpireTimeOfIncompleteChunkedMessage
-
buildProperties
-