default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.AdvancedPulsarEndpointProducerBuilder.basic() |
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.batcherBuilder(Object batcherBuilder) |
Control batching method used by the producer.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.batcherBuilder(String batcherBuilder) |
Control batching method used by the producer.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.batchingEnabled(boolean batchingEnabled) |
Control whether automatic batching of messages is enabled for the
producer.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.batchingEnabled(String batchingEnabled) |
Control whether automatic batching of messages is enabled for the
producer.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.batchingMaxMessages(int batchingMaxMessages) |
The maximum size to batch messages.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.batchingMaxMessages(String batchingMaxMessages) |
The maximum size to batch messages.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.batchingMaxPublishDelayMicros(long batchingMaxPublishDelayMicros) |
The maximum time period within which the messages sent will be
batched if batchingEnabled is true.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.batchingMaxPublishDelayMicros(String batchingMaxPublishDelayMicros) |
The maximum time period within which the messages sent will be
batched if batchingEnabled is true.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.blockIfQueueFull(boolean blockIfQueueFull) |
Whether to block the producing thread if pending messages queue is
full or to throw a ProducerQueueIsFullError.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.blockIfQueueFull(String blockIfQueueFull) |
Whether to block the producing thread if pending messages queue is
full or to throw a ProducerQueueIsFullError.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.compressionType(String compressionType) |
Compression type to use.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.compressionType(PulsarEndpointBuilderFactory.CompressionType compressionType) |
Compression type to use.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.initialSequenceId(long initialSequenceId) |
The first message published will have a sequence Id of
initialSequenceId 1.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.initialSequenceId(String initialSequenceId) |
The first message published will have a sequence Id of
initialSequenceId 1.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.lazyStartProducer(String lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.maxPendingMessages(int maxPendingMessages) |
Size of the pending massages queue.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.maxPendingMessages(String maxPendingMessages) |
Size of the pending massages queue.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.maxPendingMessagesAcrossPartitions(int maxPendingMessagesAcrossPartitions) |
The maximum number of pending messages for partitioned topics.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.maxPendingMessagesAcrossPartitions(String maxPendingMessagesAcrossPartitions) |
The maximum number of pending messages for partitioned topics.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.messageRouter(Object messageRouter) |
Custom Message Router to use.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.messageRouter(String messageRouter) |
Custom Message Router to use.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.messageRoutingMode(String messageRoutingMode) |
Message Routing Mode to use.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.messageRoutingMode(PulsarEndpointBuilderFactory.MessageRoutingMode messageRoutingMode) |
Message Routing Mode to use.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.producerName(String producerName) |
Name of the producer.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.sendTimeoutMs(int sendTimeoutMs) |
Send timeout in milliseconds.
|
default PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder |
PulsarEndpointBuilderFactory.PulsarEndpointProducerBuilder.sendTimeoutMs(String sendTimeoutMs) |
Send timeout in milliseconds.
|