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

Packages that use ConsumerBuilder

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

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

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

Modifier and Type	Method	Description
ConsumerBuilder<T>	ConsumerBuilder.acknowledgmentGroupTime(long delay, TimeUnit unit)	Sets amount of time for group consumer acknowledgments.
ConsumerBuilder<T>	ConsumerBuilder.ackTimeout(long ackTimeout, TimeUnit timeUnit)	Sets the timeout for unacknowledged messages, truncated to the nearest millisecond.
ConsumerBuilder<T>	ConsumerBuilder.ackTimeoutRedeliveryBackoff(RedeliveryBackoff ackTimeoutRedeliveryBackoff)	Sets the redelivery backoff policy for messages that are redelivered due to acknowledgement timeout.
ConsumerBuilder<T>	ConsumerBuilder.ackTimeoutTickTime(long tickTime, TimeUnit timeUnit)	Define the granularity of the ack-timeout redelivery.
ConsumerBuilder<T>	ConsumerBuilder.autoAckOldestChunkedMessageOnQueueFull(boolean autoAckOldestChunkedMessageOnQueueFull)	Buffering large number of outstanding uncompleted chunked messages can create memory pressure and it can be guarded by providing this @maxPendingChunkedMessage threshold.
ConsumerBuilder<T>	ConsumerBuilder.autoScaledReceiverQueueSizeEnabled(boolean enabled)	If this is enabled, the consumer receiver queue size is initialized as a very small value, 1 by default, and will double itself until it reaches the value set by receiverQueueSize(int), if and only if:
ConsumerBuilder<T>	ConsumerBuilder.autoUpdatePartitions(boolean autoUpdate)	If enabled, the consumer auto-subscribes for partition increases.
ConsumerBuilder<T>	ConsumerBuilder.autoUpdatePartitionsInterval(int interval, TimeUnit unit)	Sets the interval of updating partitions (default: 1 minute).
ConsumerBuilder<T>	ConsumerBuilder.batchReceivePolicy(BatchReceivePolicy batchReceivePolicy)	Sets BatchReceivePolicy for the consumer.
ConsumerBuilder<T>	TopicConsumerBuilder.build()	Complete the configuration of the topic specific options and return control back to the ConsumerBuilder instance.
ConsumerBuilder<T>	ConsumerBuilder.clone()	Create a copy of the current consumer builder.
ConsumerBuilder<T>	ConsumerBuilder.consumerEventListener(ConsumerEventListener consumerEventListener)	Sets a ConsumerEventListener for the consumer.
ConsumerBuilder<T>	ConsumerBuilder.consumerName(String consumerName)	Sets the consumer name.
ConsumerBuilder<T>	ConsumerBuilder.cryptoFailureAction(ConsumerCryptoFailureAction action)	Sets the ConsumerCryptoFailureAction to the value specified.
ConsumerBuilder<T>	ConsumerBuilder.cryptoKeyReader(CryptoKeyReader cryptoKeyReader)	Sets a CryptoKeyReader.
ConsumerBuilder<T>	ConsumerBuilder.deadLetterPolicy(DeadLetterPolicy deadLetterPolicy)	Sets dead letter policy for a consumer.
ConsumerBuilder<T>	ConsumerBuilder.defaultCryptoKeyReader(String privateKey)	Sets the default implementation of CryptoKeyReader.
ConsumerBuilder<T>	ConsumerBuilder.defaultCryptoKeyReader(Map<String,String> privateKeys)	Sets the default implementation of CryptoKeyReader.
ConsumerBuilder<T>	ConsumerBuilder.enableBatchIndexAcknowledgment(boolean batchIndexAcknowledgmentEnabled)	Enable or disable batch index acknowledgment.
ConsumerBuilder<T>	ConsumerBuilder.enableRetry(boolean retryEnable)	If enabled, the consumer auto-retries messages.
ConsumerBuilder<T>	ConsumerBuilder.expireTimeOfIncompleteChunkedMessage(long duration, TimeUnit unit)	If the producer fails to publish all the chunks of a message, then the consumer can expire incomplete chunks if the consumer doesn't receive all chunks during the expiration period (default 1 minute).
ConsumerBuilder<T>	ConsumerBuilder.intercept(ConsumerInterceptor<T>... interceptors)	Intercept Consumer.
ConsumerBuilder<T>	ConsumerBuilder.isAckReceiptEnabled(boolean isAckReceiptEnabled)	Enables or disables the acknowledgment receipt feature.
ConsumerBuilder<T>	ConsumerBuilder.keySharedPolicy(KeySharedPolicy keySharedPolicy)	Sets KeyShared subscription policy for consumer.
ConsumerBuilder<T>	ConsumerBuilder.loadConf(Map<String,Object> config)	Load the configuration from provided config map.
ConsumerBuilder<T>	ConsumerBuilder.maxAcknowledgmentGroupSize(int messageNum)	Set the number of messages for group consumer acknowledgments.
ConsumerBuilder<T>	ConsumerBuilder.maxPendingChuckedMessage(int maxPendingChuckedMessage)	Deprecated. use maxPendingChunkedMessage(int)
ConsumerBuilder<T>	ConsumerBuilder.maxPendingChunkedMessage(int maxPendingChunkedMessage)	Consumer buffers chunk messages into memory until it receives all the chunks of the original message.
ConsumerBuilder<T>	ConsumerBuilder.maxTotalReceiverQueueSizeAcrossPartitions(int maxTotalReceiverQueueSizeAcrossPartitions)	Sets the max total receiver queue size across partitions.
ConsumerBuilder<T>	ConsumerBuilder.messageCrypto(MessageCrypto messageCrypto)	Sets a MessageCrypto.
ConsumerBuilder<T>	ConsumerBuilder.messageListener(MessageListener<T> messageListener)	Sets a MessageListener for the consumer.
ConsumerBuilder<T>	ConsumerBuilder.messageListenerExecutor(MessageListenerExecutor messageListenerExecutor)	Set the MessageListenerExecutor to be used for message listeners of current consumer.
ConsumerBuilder<T>	ConsumerBuilder.messagePayloadProcessor(MessagePayloadProcessor payloadProcessor)	If configured with a non-null value, the consumer uses the processor to process the payload, including decoding it to messages and triggering the listener.
ConsumerBuilder<T>	ConsumerBuilder.negativeAckRedeliveryBackoff(RedeliveryBackoff negativeAckRedeliveryBackoff)	negativeAckRedeliveryBackoff sets the redelivery backoff policy for messages that are negatively acknowledged using `consumer.negativeAcknowledge(Messageinvalid input: '<'?> message)` but not with `consumer.negativeAcknowledge(MessageId messageId)`.
ConsumerBuilder<T>	ConsumerBuilder.negativeAckRedeliveryDelay(long redeliveryDelay, TimeUnit timeUnit)	Sets the delay to wait before re-delivering messages that have failed to be processed.
ConsumerBuilder<byte[]>	PulsarClient.newConsumer()	Create a consumer builder with no schema (Schema.BYTES) for subscribing to one or more topics.
<T> ConsumerBuilder<T>	PulsarClient.newConsumer(Schema<T> schema)	Create a consumer builder with a specific schema for subscribing on a specific topic
ConsumerBuilder<T>	ConsumerBuilder.patternAutoDiscoveryPeriod(int periodInMinutes)	Sets topic's auto-discovery period when using a pattern for topic's consumer.
ConsumerBuilder<T>	ConsumerBuilder.patternAutoDiscoveryPeriod(int interval, TimeUnit unit)	Sets topic's auto-discovery period when using a pattern for topic's consumer.
ConsumerBuilder<T>	ConsumerBuilder.poolMessages(boolean poolMessages)	Enable pooling of messages and the underlying data buffers.
ConsumerBuilder<T>	ConsumerBuilder.priorityLevel(int priorityLevel)	Shared subscription
ConsumerBuilder<T>	ConsumerBuilder.properties(Map<String,String> properties)	Add all the properties in the provided map to the consumer.
ConsumerBuilder<T>	ConsumerBuilder.property(String key, String value)	Sets a name/value property with this consumer.
ConsumerBuilder<T>	ConsumerBuilder.readCompacted(boolean readCompacted)	If enabled, the consumer reads messages from the compacted topic rather than the full message topic backlog.
ConsumerBuilder<T>	ConsumerBuilder.receiverQueueSize(int receiverQueueSize)	Sets the size of the consumer receive queue.
ConsumerBuilder<T>	ConsumerBuilder.replicateSubscriptionState(boolean replicateSubscriptionState)
ConsumerBuilder<T>	ConsumerBuilder.startMessageIdInclusive()	Sets the consumer to include the given position of any reset operation like Consumer.seek(long) or Consumer.seek(MessageId)}.
ConsumerBuilder<T>	ConsumerBuilder.startPaused(boolean paused)	Starts the consumer in a paused state.
ConsumerBuilder<T>	ConsumerBuilder.subscriptionInitialPosition(SubscriptionInitialPosition subscriptionInitialPosition)	Sets the SubscriptionInitialPosition for the consumer.
ConsumerBuilder<T>	ConsumerBuilder.subscriptionMode(SubscriptionMode subscriptionMode)	Selects the subscription mode to be used when subscribing to a topic.
ConsumerBuilder<T>	ConsumerBuilder.subscriptionName(String subscriptionName)	Specify the subscription name for this consumer.
ConsumerBuilder<T>	ConsumerBuilder.subscriptionProperties(Map<String,String> subscriptionProperties)	Specify the subscription properties for this subscription.
ConsumerBuilder<T>	ConsumerBuilder.subscriptionTopicsMode(RegexSubscriptionMode regexSubscriptionMode)	Determines which topics this consumer should be subscribed to - Persistent, Non-Persistent, or both.
ConsumerBuilder<T>	ConsumerBuilder.subscriptionType(SubscriptionType subscriptionType)	Select the subscription type to be used when subscribing to a topic.
ConsumerBuilder<T>	ConsumerBuilder.topic(String... topicNames)	Specify the topics this consumer subscribes to.
ConsumerBuilder<T>	ConsumerBuilder.topicConfiguration(String topicName, Consumer<TopicConsumerBuilder<T>> builderConsumer)	Configure topic specific options to override those set at the ConsumerBuilder level.
ConsumerBuilder<T>	ConsumerBuilder.topicConfiguration(Pattern topicsPattern, Consumer<TopicConsumerBuilder<T>> builderConsumer)	Configure topic specific options to override those set at the ConsumerBuilder level.
ConsumerBuilder<T>	ConsumerBuilder.topics(List<String> topicNames)	Specify a list of topics that this consumer subscribes to.
ConsumerBuilder<T>	ConsumerBuilder.topicsPattern(String topicsPattern)	Specify a pattern for topics(not contains the partition suffix) that this consumer subscribes to.
ConsumerBuilder<T>	ConsumerBuilder.topicsPattern(Pattern topicsPattern)	Specify a pattern for topics(not contains the partition suffix) that this consumer subscribes to.