Uses of Interface
org.apache.pulsar.client.api.ProducerBuilder

Packages that use ProducerBuilder

Package	Description
org.apache.pulsar.client.api	Pulsar Client API.

Uses of ProducerBuilder in org.apache.pulsar.client.api

Methods in org.apache.pulsar.client.api that return ProducerBuilder

Modifier and Type	Method	Description
ProducerBuilder<T>	ProducerBuilder.accessMode(ProducerAccessMode accessMode)	Configure the type of access mode that the producer requires on the topic.
ProducerBuilder<T>	ProducerBuilder.addEncryptionKey(String key)	Add public encryption key, used by producer to encrypt the data key.
ProducerBuilder<T>	ProducerBuilder.autoUpdatePartitions(boolean autoUpdate)	If enabled, partitioned producer will automatically discover new partitions at runtime.
ProducerBuilder<T>	ProducerBuilder.autoUpdatePartitionsInterval(int interval, TimeUnit unit)	Set the interval of updating partitions.
ProducerBuilder<T>	ProducerBuilder.batcherBuilder(BatcherBuilder batcherBuilder)	Set the batcher builder BatcherBuilder of the producer.
ProducerBuilder<T>	ProducerBuilder.batchingMaxBytes(int batchingMaxBytes)	Set the maximum number of bytes permitted in a batch.
ProducerBuilder<T>	ProducerBuilder.batchingMaxMessages(int batchMessagesMaxMessagesPerBatch)	Set the maximum number of messages permitted in a batch.
ProducerBuilder<T>	ProducerBuilder.batchingMaxPublishDelay(long batchDelay, TimeUnit timeUnit)	Set the time period within which messages sent will be batched if batch messages are enabled.
ProducerBuilder<T>	ProducerBuilder.blockIfQueueFull(boolean blockIfQueueFull)	Set whether the Producer.send(T) and Producer.sendAsync(T) operations should block when the outgoing message queue is full.
ProducerBuilder<T>	ProducerBuilder.chunkMaxMessageSize(int chunkMaxMessageSize)	Max chunk-message size in bytes.
ProducerBuilder<T>	ProducerBuilder.clone()	Create a copy of the current ProducerBuilder.
ProducerBuilder<T>	ProducerBuilder.compressionType(CompressionType compressionType)	Set the compression type for the producer.
ProducerBuilder<T>	ProducerBuilder.cryptoFailureAction(ProducerCryptoFailureAction action)	Set the ProducerCryptoFailureAction to the value specified.
ProducerBuilder<T>	ProducerBuilder.cryptoKeyReader(CryptoKeyReader cryptoKeyReader)	Sets a CryptoKeyReader.
ProducerBuilder<T>	ProducerBuilder.defaultCryptoKeyReader(String publicKey)	Sets the default implementation of CryptoKeyReader.
ProducerBuilder<T>	ProducerBuilder.defaultCryptoKeyReader(Map<String,String> publicKeys)	Sets the default implementation of CryptoKeyReader.
ProducerBuilder<T>	ProducerBuilder.enableBatching(boolean enableBatching)	Set automatic batching of messages for the producer.
ProducerBuilder<T>	ProducerBuilder.enableChunking(boolean enableChunking)	If a message's size is higher than the broker's allowed max publish-payload size, enableChunking allows the producer to split the message into multiple chunks and publish it to the broker separately and in order.
ProducerBuilder<T>	ProducerBuilder.enableLazyStartPartitionedProducers(boolean lazyStartPartitionedProducers)	This config affects Shared mode producers of partitioned topics only.
ProducerBuilder<T>	ProducerBuilder.enableMultiSchema(boolean multiSchema)	Set the multiple schema mode for producer.
ProducerBuilder<T>	ProducerBuilder.hashingScheme(HashingScheme hashingScheme)	Change the HashingScheme used to choose the partition on which to publish a particular message.
ProducerBuilder<T>	ProducerBuilder.initialSequenceId(long initialSequenceId)	Set the baseline for sequence ids for messages published by the producer.
ProducerBuilder<T>	ProducerBuilder.intercept(ProducerInterceptor... interceptors)	Add a set of ProducerInterceptor to the producer.
ProducerBuilder<T>	ProducerBuilder.intercept(ProducerInterceptor<T>... interceptors)	Deprecated.
ProducerBuilder<T>	ProducerBuilder.loadConf(Map<String,Object> config)	Load the configuration from provided config map.
ProducerBuilder<T>	ProducerBuilder.maxPendingMessages(int maxPendingMessages)	Set the max size of the queue holding the messages pending to receive an acknowledgment from the broker.
ProducerBuilder<T>	ProducerBuilder.maxPendingMessagesAcrossPartitions(int maxPendingMessagesAcrossPartitions)	Deprecated.
ProducerBuilder<T>	ProducerBuilder.messageCrypto(MessageCrypto messageCrypto)	Sets a MessageCrypto.
ProducerBuilder<T>	ProducerBuilder.messageRouter(MessageRouter messageRouter)	Set a custom message routing policy by passing an implementation of MessageRouter.
ProducerBuilder<T>	ProducerBuilder.messageRoutingMode(MessageRoutingMode messageRoutingMode)	Set the MessageRoutingMode for a partitioned producer.
ProducerBuilder<byte[]>	PulsarClient.newProducer()	Create a producer builder that can be used to configure and construct a producer with default Schema.BYTES.
<T> ProducerBuilder<T>	PulsarClient.newProducer(Schema<T> schema)	Create a producer builder that can be used to configure and construct a producer with the specified schema.
ProducerBuilder<T>	ProducerBuilder.producerName(String producerName)	Specify a name for the producer.
ProducerBuilder<T>	ProducerBuilder.properties(Map<String,String> properties)	Add all the properties in the provided map to the producer.
ProducerBuilder<T>	ProducerBuilder.property(String key, String value)	Set a name/value property for this producer.
ProducerBuilder<T>	ProducerBuilder.roundRobinRouterBatchingPartitionSwitchFrequency(int frequency)	Set the partition switch frequency while batching of messages is enabled and using round-robin routing mode for non-keyed messages.
ProducerBuilder<T>	ProducerBuilder.sendTimeout(int sendTimeout, TimeUnit unit)	Set the send timeout (default: 30 seconds).
ProducerBuilder<T>	ProducerBuilder.topic(String topicName)	Specify the topic this producer will be publishing on.