public class PulsarConsumerBuilder<T>
extends org.apache.pulsar.client.impl.ConsumerBuilderImpl<T>
Constructor and Description |
---|
PulsarConsumerBuilder(org.apache.pulsar.client.api.PulsarClient client,
org.apache.pulsar.client.api.Schema<T> schema) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<org.apache.pulsar.client.api.Consumer<T>> |
subscribeAsync() |
acknowledgmentGroupTime, ackTimeout, ackTimeoutRedeliveryBackoff, ackTimeoutTickTime, autoAckOldestChunkedMessageOnQueueFull, autoUpdatePartitions, autoUpdatePartitionsInterval, batchReceivePolicy, clone, consumerEventListener, consumerName, cryptoFailureAction, cryptoKeyReader, deadLetterPolicy, defaultCryptoKeyReader, defaultCryptoKeyReader, enableBatchIndexAcknowledgment, enableRetry, expireTimeOfIncompleteChunkedMessage, getClient, getConf, getInterceptorList, getSchema, intercept, isAckReceiptEnabled, keySharedPolicy, loadConf, maxPendingChuckedMessage, maxPendingChunkedMessage, maxTotalReceiverQueueSizeAcrossPartitions, messageCrypto, messageListener, messagePayloadProcessor, negativeAckRedeliveryBackoff, negativeAckRedeliveryDelay, patternAutoDiscoveryPeriod, patternAutoDiscoveryPeriod, poolMessages, priorityLevel, properties, property, readCompacted, receiverQueueSize, replicateSubscriptionState, startMessageIdInclusive, startPaused, subscribe, subscriptionInitialPosition, subscriptionMode, subscriptionName, subscriptionProperties, subscriptionTopicsMode, subscriptionType, topic, topics, topicsPattern, topicsPattern, toString
public PulsarConsumerBuilder(org.apache.pulsar.client.api.PulsarClient client, org.apache.pulsar.client.api.Schema<T> schema)
public CompletableFuture<org.apache.pulsar.client.api.Consumer<T>> subscribeAsync()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.