Class PulsarProducerProperties
java.lang.Object
org.springframework.pulsar.autoconfigure.ProducerConfigProperties
org.springframework.pulsar.spring.cloud.stream.binder.properties.PulsarProducerProperties
Pulsar producer 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.ProducerConfigProperties
buildProperties, getAutoUpdatePartitions, getAutoUpdatePartitionsInterval, getBatchingEnabled, getBatchingMaxBytes, getBatchingMaxMessages, getBatchingMaxPublishDelay, getBatchingPartitionSwitchFrequencyByPublishDelay, getBlockIfQueueFull, getCache, getChunkingEnabled, getCompressionType, getCryptoFailureAction, getEncryptionKeys, getHashingScheme, getInitialSequenceId, getLazyStartPartitionedProducers, getMaxPendingMessages, getMaxPendingMessagesAcrossPartitions, getMessageRoutingMode, getMultiSchema, getProducerAccessMode, getProducerName, getProperties, getSendTimeout, getTopicName, setAutoUpdatePartitions, setAutoUpdatePartitionsInterval, setBatchingEnabled, setBatchingMaxBytes, setBatchingMaxMessages, setBatchingMaxPublishDelay, setBatchingPartitionSwitchFrequencyByPublishDelay, setBlockIfQueueFull, setChunkingEnabled, setCompressionType, setCryptoFailureAction, setEncryptionKeys, setHashingScheme, setInitialSequenceId, setLazyStartPartitionedProducers, setMaxPendingMessages, setMaxPendingMessagesAcrossPartitions, setMessageRoutingMode, setMultiSchema, setProducerAccessMode, setProducerName, setProperties, setSendTimeout, setTopicName
-
Constructor Details
-
PulsarProducerProperties
public PulsarProducerProperties()
-
-
Method Details
-
getSchemaType
-
setSchemaType
-
getMessageType
-
setMessageType
-
getMessageKeyType
-
setMessageKeyType
-
getPartitionCount
-
setPartitionCount
-