Class PulsarProducerProperties

java.lang.Object

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

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

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

public class PulsarProducerProperties
extends ProducerConfigProperties

Pulsar producer properties used by the binder.

Author:

Soby Chacko, Chris Bono

Nested Class Summary

Nested classes/interfaces inherited from class ProducerConfigProperties

ProducerConfigProperties.Batching

Nested classes/interfaces inherited from class PulsarProperties.Producer

PulsarProperties.Producer.Cache

Constructor Summary

Constructors

Constructor	Description
PulsarProducerProperties()

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 ProducerConfigProperties

getAutoUpdatePartitions, getAutoUpdatePartitionsInterval, getBatch, getBlockIfQueueFull, getCryptoFailureAction, getEncryptionKeys, getInitialSequenceId, getLazyStartPartitionedProducers, getMaxPendingMessages, getMaxPendingMessagesAcrossPartitions, getMultiSchema, getProperties, setAutoUpdatePartitions, setAutoUpdatePartitionsInterval, setBlockIfQueueFull, setCryptoFailureAction, setEncryptionKeys, setInitialSequenceId, setLazyStartPartitionedProducers, setMaxPendingMessages, setMaxPendingMessagesAcrossPartitions, setMultiSchema, setProperties, toAllProducerPropertiesMap, toBaseProducerPropertiesMap, toExtendedProducerPropertiesMap

Methods inherited from class PulsarProperties.Producer

getAccessMode, getCache, getCompressionType, getHashingScheme, getMessageRoutingMode, getName, getSendTimeout, getTopicName, isBatchingEnabled, isChunkingEnabled, setAccessMode, setBatchingEnabled, setChunkingEnabled, setCompressionType, setHashingScheme, setMessageRoutingMode, setName, setSendTimeout, setTopicName

Methods inherited from class Object

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

Constructor Details

PulsarProducerProperties

public PulsarProducerProperties()

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)