Class PulsarProperties.Producer
java.lang.Object
org.springframework.boot.autoconfigure.pulsar.PulsarProperties.Producer
- Enclosing class:
- PulsarProperties
-
Nested Class Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.client.api.ProducerAccessMode
getCache()
org.apache.pulsar.client.api.CompressionType
org.apache.pulsar.client.api.HashingScheme
org.apache.pulsar.client.api.MessageRoutingMode
getName()
boolean
boolean
void
setAccessMode
(org.apache.pulsar.client.api.ProducerAccessMode accessMode) void
setBatchingEnabled
(boolean batchingEnabled) void
setChunkingEnabled
(boolean chunkingEnabled) void
setCompressionType
(org.apache.pulsar.client.api.CompressionType compressionType) void
setHashingScheme
(org.apache.pulsar.client.api.HashingScheme hashingScheme) void
setMessageRoutingMode
(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) void
void
setSendTimeout
(Duration sendTimeout) void
setTopicName
(String topicName)
-
Constructor Details
-
Producer
public Producer()
-
-
Method Details
-
getName
-
setName
-
getTopicName
-
setTopicName
-
getSendTimeout
-
setSendTimeout
-
getMessageRoutingMode
public org.apache.pulsar.client.api.MessageRoutingMode getMessageRoutingMode() -
setMessageRoutingMode
public void setMessageRoutingMode(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) -
getHashingScheme
public org.apache.pulsar.client.api.HashingScheme getHashingScheme() -
setHashingScheme
public void setHashingScheme(org.apache.pulsar.client.api.HashingScheme hashingScheme) -
isBatchingEnabled
public boolean isBatchingEnabled() -
setBatchingEnabled
public void setBatchingEnabled(boolean batchingEnabled) -
isChunkingEnabled
public boolean isChunkingEnabled() -
setChunkingEnabled
public void setChunkingEnabled(boolean chunkingEnabled) -
getCompressionType
public org.apache.pulsar.client.api.CompressionType getCompressionType() -
setCompressionType
public void setCompressionType(org.apache.pulsar.client.api.CompressionType compressionType) -
getAccessMode
public org.apache.pulsar.client.api.ProducerAccessMode getAccessMode() -
setAccessMode
public void setAccessMode(org.apache.pulsar.client.api.ProducerAccessMode accessMode) -
getCache
-