Class PulsarConsumerProperties

java.lang.Object

org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer

org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarConsumerProperties

public class PulsarConsumerProperties
extends ConsumerConfigProperties

Pulsar consumer properties used by the binder.

Author:

Soby Chacko, Chris Bono

Nested Class Summary

Nested classes/interfaces inherited from class ConsumerConfigProperties

ConsumerConfigProperties.Acknowledgement, ConsumerConfigProperties.Chunking, ConsumerConfigProperties.Subscription

Nested classes/interfaces inherited from class PulsarProperties.Consumer

PulsarProperties.Consumer.DeadLetterPolicy

Constructor Summary

Constructors

Constructor	Description
PulsarConsumerProperties()

Method Summary

Modifier and Type	Method	Description
@Nullable Class<?>	getMessageKeyType()
@Nullable Class<?>	getMessageType()
@Nullable Integer	getPartitionCount()
@Nullable org.apache.pulsar.common.schema.SchemaType	getSchemaType()
void	setMessageKeyType(@Nullable Class<?> messageKeyType)
void	setMessageType(@Nullable Class<?> messageType)
void	setPartitionCount(Integer partitionCount)
void	setSchemaType(@Nullable org.apache.pulsar.common.schema.SchemaType schemaType)

Methods inherited from class ConsumerConfigProperties

getAck, getAutoUpdatePartitions, getAutoUpdatePartitionsInterval, getChunk, getCryptoFailureAction, getMaxTotalReceiverQueueSizeAcrossPartitions, getPatternAutoDiscoveryPeriod, getPoolMessages, getProperties, getReceiverQueueSize, getResetIncludeHead, getStartPaused, getSubscription, setAutoUpdatePartitions, setAutoUpdatePartitionsInterval, setCryptoFailureAction, setMaxTotalReceiverQueueSizeAcrossPartitions, setPatternAutoDiscoveryPeriod, setPoolMessages, setProperties, setReceiverQueueSize, setResetIncludeHead, setStartPaused, toAllConsumerPropertiesMap, toBaseConsumerPropertiesMap, toExtendedConsumerPropertiesMap

Methods inherited from class PulsarProperties.Consumer

getDeadLetterPolicy, getName, getPriorityLevel, getTopics, getTopicsPattern, isReadCompacted, isRetryEnable, setDeadLetterPolicy, setName, setPriorityLevel, setReadCompacted, setRetryEnable, setTopics, setTopicsPattern

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PulsarConsumerProperties

public PulsarConsumerProperties()

Method Details

getSchemaType

public @Nullable org.apache.pulsar.common.schema.SchemaType getSchemaType()

setSchemaType

public void setSchemaType(@Nullable org.apache.pulsar.common.schema.SchemaType schemaType)

getMessageType

public @Nullable Class<?> getMessageType()

setMessageType

public void setMessageType(@Nullable Class<?> messageType)

getMessageKeyType

public @Nullable Class<?> getMessageKeyType()

setMessageKeyType

public void setMessageKeyType(@Nullable Class<?> messageKeyType)

getPartitionCount

public @Nullable Integer getPartitionCount()

setPartitionCount

public void setPartitionCount(Integer partitionCount)