クラス PulsarProperties.Producer
java.lang.ObjectSE
org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer
- 含まれているクラス:
PulsarProperties
- 導入:
- 4.0.0
- 作成者:
- Chris Bono, Phillip Webb, Swamy Mavuri, Vedran Pavic
ネストされたクラスの概要
ネストされたクラスコンストラクター概要
コンストラクター方法の概要
修飾子と型メソッド説明org.apache.pulsar.client.api.ProducerAccessModegetCache()@Nullable org.apache.pulsar.client.api.CompressionTypeorg.apache.pulsar.client.api.HashingSchemeorg.apache.pulsar.client.api.MessageRoutingMode@Nullable StringSEgetName()@Nullable StringSEbooleanbooleanvoidsetAccessMode(org.apache.pulsar.client.api.ProducerAccessMode accessMode) voidsetBatchingEnabled(boolean batchingEnabled) voidsetChunkingEnabled(boolean chunkingEnabled) voidsetCompressionType(@Nullable org.apache.pulsar.client.api.CompressionType compressionType) voidsetHashingScheme(org.apache.pulsar.client.api.HashingScheme hashingScheme) voidsetMessageRoutingMode(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) voidvoidsetSendTimeout(DurationSE sendTimeout) voidsetTopicName(@Nullable StringSE topicName)
コンストラクターの詳細
Producer
public Producer()
方法の詳細
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 @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