Class PulsarConsumerProperties
java.lang.Object
org.springframework.pulsar.autoconfigure.ConsumerConfigProperties
org.springframework.pulsar.spring.cloud.stream.binder.properties.PulsarConsumerProperties
Pulsar consumer properties used by the binder.
- Author:
- Soby Chacko, Chris Bono
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionClass<?>Class<?>org.apache.pulsar.common.schema.SchemaTypevoidsetMessageKeyType(Class<?> messageKeyType) voidsetMessageType(Class<?> messageType) voidsetPartitionCount(Integer partitionCount) voidsetSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType) Methods inherited from class org.springframework.pulsar.autoconfigure.ConsumerConfigProperties
buildProperties, getAcknowledgementsGroupTime, getAckReceiptEnabled, getAckTimeout, getAutoAckOldestChunkedMessageOnQueueFull, getAutoUpdatePartitions, getAutoUpdatePartitionsInterval, getBatchIndexAckEnabled, getConsumerName, getCryptoFailureAction, getDeadLetterPolicy, getExpireTimeOfIncompleteChunkedMessage, getMaxPendingChunkedMessage, getMaxTotalReceiverQueueSizeAcrossPartitions, getNegativeAckRedeliveryDelay, getPatternAutoDiscoveryPeriod, getPoolMessages, getPriorityLevel, getProperties, getReadCompacted, getReceiverQueueSize, getRegexSubscriptionMode, getReplicateSubscriptionState, getResetIncludeHead, getRetryEnable, getStartPaused, getSubscriptionInitialPosition, getSubscriptionMode, getSubscriptionName, getSubscriptionProperties, getSubscriptionType, getTickDuration, getTopics, getTopicsPattern, setAcknowledgementsGroupTime, setAckReceiptEnabled, setAckTimeout, setAutoAckOldestChunkedMessageOnQueueFull, setAutoUpdatePartitions, setAutoUpdatePartitionsInterval, setBatchIndexAckEnabled, setConsumerName, setCryptoFailureAction, setDeadLetterPolicy, setExpireTimeOfIncompleteChunkedMessage, setMaxPendingChunkedMessage, setMaxTotalReceiverQueueSizeAcrossPartitions, setNegativeAckRedeliveryDelay, setPatternAutoDiscoveryPeriod, setPoolMessages, setPriorityLevel, setProperties, setReadCompacted, setReceiverQueueSize, setRegexSubscriptionMode, setReplicateSubscriptionState, setResetIncludeHead, setRetryEnable, setStartPaused, setSubscriptionInitialPosition, setSubscriptionMode, setSubscriptionName, setSubscriptionProperties, setSubscriptionType, setTickDuration, setTopics, setTopicsPattern
-
Constructor Details
-
PulsarConsumerProperties
public PulsarConsumerProperties()
-
-
Method Details
-
getSchemaType
-
setSchemaType
-
getMessageType
-
setMessageType
-
getMessageKeyType
-
setMessageKeyType
-
getPartitionCount
-
setPartitionCount
-