Class PulsarProperties.Producer

java.lang.Object
org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer
Enclosing class:
PulsarProperties
public static class PulsarProperties.Producer extends Object
Since:
4.0.0
Author:
Chris Bono, Phillip Webb, Swamy Mavuri, Vedran Pavic

  • Constructor Details

    • Producer

      public Producer()

  • Method Details

    • getName

      public @Nullable String getName()

    • setName

      public void setName(@Nullable String name)

    • getTopicName

      public @Nullable String getTopicName()

    • setTopicName

      public void setTopicName(@Nullable String topicName)

    • getSendTimeout

      public Duration getSendTimeout()

    • setSendTimeout

      public void setSendTimeout(Duration sendTimeout)

    • 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 @Nullable org.apache.pulsar.client.api.CompressionType getCompressionType()

    • setCompressionType

      public void setCompressionType(@Nullable 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

      public PulsarProperties.Producer.Cache getCache()