程序包 org.springframework.boot.autoconfigure.pulsar

类 PulsarProperties.Producer

java.lang.Object
org.springframework.boot.autoconfigure.pulsar.PulsarProperties.Producer
封闭类:
PulsarProperties
public static class PulsarProperties.Producer extends Object

  • 构造器详细资料

    • Producer

      public Producer()

  • 方法详细资料

    • getName

      public String getName()

    • setName

      public void setName(String name)

    • getTopicName

      public String getTopicName()

    • setTopicName

      public void setTopicName(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 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

      public PulsarProperties.Producer.Cache getCache()