Index (Pulsar Client :: API 2.4.2 API)

A B C D E F G H I J K L M N O P R S T U V W

A

acknowledge(Message<?>) - Method in interface org.apache.pulsar.client.api.Consumer: Acknowledge the consumption of a single message
acknowledge(MessageId) - Method in interface org.apache.pulsar.client.api.Consumer: Acknowledge the consumption of a single message, identified by its MessageId.
acknowledgeAsync(Message<?>) - Method in interface org.apache.pulsar.client.api.Consumer: Asynchronously acknowledge the consumption of a single message
acknowledgeAsync(MessageId) - Method in interface org.apache.pulsar.client.api.Consumer: Asynchronously acknowledge the consumption of a single message
acknowledgeCumulative(Message<?>) - Method in interface org.apache.pulsar.client.api.Consumer: Acknowledge the reception of all the messages in the stream up to (and including) the provided message.
acknowledgeCumulative(MessageId) - Method in interface org.apache.pulsar.client.api.Consumer: Acknowledge the reception of all the messages in the stream up to (and including) the provided message.
acknowledgeCumulativeAsync(Message<?>) - Method in interface org.apache.pulsar.client.api.Consumer: Asynchronously Acknowledge the reception of all the messages in the stream up to (and including) the provided message.
acknowledgeCumulativeAsync(MessageId) - Method in interface org.apache.pulsar.client.api.Consumer: Asynchronously Acknowledge the reception of all the messages in the stream up to (and including) the provided message.
acknowledgmentGroupTime(long, TimeUnit) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Group the consumer acknowledgments for the specified time.
ackTimeout(long, TimeUnit) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Set the timeout for unacked messages, truncated to the nearest millisecond.
ackTimeoutTickTime(long, TimeUnit) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Define the granularity of the ack-timeout redelivery.
addEncryptionKey(String) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Add public encryption key, used by producer to encrypt the data key.
addProperty(String, String) - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinitionBuilder: Set schema info properties
aliases(String...) - Method in interface org.apache.pulsar.client.api.schema.FieldSchemaBuilder: The optional name aliases of this field.
allowTlsInsecureConnection(boolean) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Configure whether the Pulsar client accept untrusted TLS certificate from broker (default: false)
AlreadyClosedException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.AlreadyClosedException
AuthData - Class in org.apache.pulsar.common.api
AuthData() - Constructor for class org.apache.pulsar.common.api.AuthData
authenticate(AuthData) - Method in interface org.apache.pulsar.client.api.AuthenticationDataProvider: For mutual authentication, This method use passed in `data` to evaluate and challenge, then returns null if authentication has completed; returns authenticated data back to server side, if authentication has not completed.
Authentication - Interface in org.apache.pulsar.client.api: Interface of authentication providers.
authentication(Authentication) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set the authentication provider to use in the Pulsar client instance.
authentication(String, String) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Configure the authentication provider to use in the Pulsar client instance.
authentication(String, Map<String, String>) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Configure the authentication provider to use in the Pulsar client instance using a config map.
AuthenticationDataProvider - Interface in org.apache.pulsar.client.api: Interface for accessing data which are used in variety of authentication schemes on client side
AuthenticationException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.AuthenticationException
AuthenticationFactory - Class in org.apache.pulsar.client.api: Factory class that allows to create Authentication instances for all the supported authentication methods.
AuthenticationFactory() - Constructor for class org.apache.pulsar.client.api.AuthenticationFactory
authenticationStage(String, AuthenticationDataProvider, Map<String, String>, CompletableFuture<Map<String, String>>) - Method in interface org.apache.pulsar.client.api.Authentication: An authentication Stage.
AuthorizationException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.AuthorizationException
AUTO() - Static method in interface org.apache.pulsar.client.api.Schema: Deprecated.
AUTO_CONSUME() - Static method in interface org.apache.pulsar.client.api.Schema: Create a schema instance that automatically deserialize messages based on the current topic schema.
AUTO_PRODUCE_BYTES() - Static method in interface org.apache.pulsar.client.api.Schema: Create a schema instance that accepts a serialized payload and validates it against the topic schema.
autoUpdatePartitions(boolean) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: If enabled, the consumer will auto subscribe for partitions increasement.
autoUpdatePartitions(boolean) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: If enabled, partitioned producer will automatically discover new partitions at runtime.
AVRO(Class<T>) - Static method in interface org.apache.pulsar.client.api.Schema: Create a Avro schema type by default configuration of the class
AVRO(SchemaDefinition<T>) - Static method in interface org.apache.pulsar.client.api.Schema: Create a Avro schema type with schema definition

B

BatcherBuilder - Interface in org.apache.pulsar.client.api: Batcher builder
batcherBuilder(BatcherBuilder) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set the batcher builder BatcherBuilder of the producer.
batchingMaxMessages(int) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set the maximum number of messages permitted in a batch.
batchingMaxPublishDelay(long, TimeUnit) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set the time period within which the messages sent will be batched default: 1 ms if batch messages are enabled.
BatchMessageContainer - Interface in org.apache.pulsar.client.api: Batch message container for individual messages being published until they are batched and sent to broker
becameActive(Consumer<?>, int) - Method in interface org.apache.pulsar.client.api.ConsumerEventListener: Notified when the consumer group is changed, and the consumer becomes the active consumer.
becameInactive(Consumer<?>, int) - Method in interface org.apache.pulsar.client.api.ConsumerEventListener: Notified when the consumer group is changed, and the consumer is still inactive or becomes inactive.
beforeConsume(Consumer<T>, Message<T>) - Method in interface org.apache.pulsar.client.api.ConsumerInterceptor: This is called just before the message is returned by Consumer.receive(), MessageListener.received(Consumer, Message) or the CompletableFuture returned by Consumer.receiveAsync() completes.
beforeSend(Producer<T>, Message<T>) - Method in interface org.apache.pulsar.client.api.ProducerInterceptor: This is called from Producer.send(Object) and Producer.sendAsync(Object) methods, before send the message to the brokers.
blockIfQueueFull(boolean) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set whether the Producer.send(T) and Producer.sendAsync(T) operations should block when the outgoing message queue is full.
BOOL - Static variable in interface org.apache.pulsar.client.api.Schema: Boolean Schema
BrokerMetadataException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.BrokerMetadataException
BrokerPersistenceException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.BrokerPersistenceException
build() - Method in interface org.apache.pulsar.client.api.BatcherBuilder: Build a new batch message container.
build() - Method in interface org.apache.pulsar.client.api.ClientBuilder: Construct the final PulsarClient instance
build() - Method in interface org.apache.pulsar.client.api.schema.GenericRecordBuilder: Build a generic record.
build(SchemaType) - Method in interface org.apache.pulsar.client.api.schema.RecordSchemaBuilder: Build the schema info.
build() - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinitionBuilder: Build the schema definition.
builder() - Static method in interface org.apache.pulsar.client.api.PulsarClient: Get a new builder instance that can used to configure and build a PulsarClient instance.
builder() - Static method in interface org.apache.pulsar.client.api.schema.SchemaDefinition: Get a new builder instance that can used to configure and build a SchemaDefinition instance.
BYTEBUFFER - Static variable in interface org.apache.pulsar.client.api.Schema: ByteBuffer Schema.
BYTES - Static variable in interface org.apache.pulsar.client.api.Schema: Schema that doesn't perform any encoding on the message payloads.

C

ChecksumException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.ChecksumException
choosePartition(Message<?>) - Method in interface org.apache.pulsar.client.api.MessageRouter: Deprecated.
since 1.22.0. Please use MessageRouter.choosePartition(Message, TopicMetadata) instead.
choosePartition(Message<?>, TopicMetadata) - Method in interface org.apache.pulsar.client.api.MessageRouter: Choose a partition based on msg and the topic metadata.
clear() - Method in interface org.apache.pulsar.client.api.BatchMessageContainer: Clear the message batch container.
clear(String) - Method in interface org.apache.pulsar.client.api.schema.GenericRecordBuilder: Clears the value of the given field.
clear(Field) - Method in interface org.apache.pulsar.client.api.schema.GenericRecordBuilder: Clears the value of the given field.
ClientBuilder - Interface in org.apache.pulsar.client.api: Builder interface that is used to configure and construct a PulsarClient instance.
clock(Clock) - Method in interface org.apache.pulsar.client.api.ClientBuilder: The clock used by the pulsar client.
clone() - Method in interface org.apache.pulsar.client.api.ClientBuilder: Create a copy of the current client builder.
clone() - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Create a copy of the current consumer builder.
clone() - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Create a copy of the current ProducerBuilder.
clone() - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Create a copy of the current ReaderBuilder.
close() - Method in interface org.apache.pulsar.client.api.Consumer: Close the consumer and stop the broker to push more messages.
close() - Method in interface org.apache.pulsar.client.api.ConsumerInterceptor: Close the interceptor.
close() - Method in interface org.apache.pulsar.client.api.Producer: Close the producer and releases resources allocated.
close() - Method in interface org.apache.pulsar.client.api.ProducerInterceptor: Close the interceptor.
close() - Method in interface org.apache.pulsar.client.api.PulsarClient: Close the PulsarClient and release all the resources.
closeAsync() - Method in interface org.apache.pulsar.client.api.Consumer: Asynchronously close the consumer and stop the broker to push more messages
closeAsync() - Method in interface org.apache.pulsar.client.api.Producer: Close the producer and releases resources allocated.
closeAsync() - Method in interface org.apache.pulsar.client.api.PulsarClient: Asynchronously close the PulsarClient and release all the resources.
closeAsync() - Method in interface org.apache.pulsar.client.api.Reader: Asynchronously close the reader and stop the broker to push more messages
CompressionType - Enum in org.apache.pulsar.client.api: The compression type that can be specified on a Producer.
compressionType(CompressionType) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set the compression type for the producer.
CONF_DELIVERY_AFTER_SECONDS - Static variable in interface org.apache.pulsar.client.api.TypedMessageBuilder
CONF_DELIVERY_AT - Static variable in interface org.apache.pulsar.client.api.TypedMessageBuilder
CONF_DISABLE_REPLICATION - Static variable in interface org.apache.pulsar.client.api.TypedMessageBuilder
CONF_EVENT_TIME - Static variable in interface org.apache.pulsar.client.api.TypedMessageBuilder
CONF_KEY - Static variable in interface org.apache.pulsar.client.api.TypedMessageBuilder
CONF_PROPERTIES - Static variable in interface org.apache.pulsar.client.api.TypedMessageBuilder
CONF_REPLICATION_CLUSTERS - Static variable in interface org.apache.pulsar.client.api.TypedMessageBuilder
CONF_SEQUENCE_ID - Static variable in interface org.apache.pulsar.client.api.TypedMessageBuilder
configure(Map<String, String>) - Method in interface org.apache.pulsar.client.api.Authentication: Deprecated.
This method will be deleted on version 2.0, instead please use configure(String encodedAuthParamString) which is in EncodedAuthenticationParameterSupport for now and will be integrated into this interface.
configure(String) - Method in interface org.apache.pulsar.client.api.EncodedAuthenticationParameterSupport: Plugins which use ":" and/or "," in a configuration parameter value need to implement this interface.
configureSchemaInfo(String, String, SchemaInfo) - Method in interface org.apache.pulsar.client.api.Schema: Configure the schema to use the provided schema info.
ConnectException(Throwable) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.ConnectException
ConnectException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.ConnectException
connectionsPerBroker(int) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Sets the max number of connection that the client library will open to a single broker.
connectionTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set the duration of time to wait for a connection to a broker to be established.
Consumer<T> - Interface in org.apache.pulsar.client.api: An interface that abstracts behavior of Pulsar's consumer.
ConsumerBuilder<T> - Interface in org.apache.pulsar.client.api: ConsumerBuilder is used to configure and create instances of Consumer.
ConsumerBusyException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.ConsumerBusyException
ConsumerCryptoFailureAction - Enum in org.apache.pulsar.client.api: The action a consumer should take when a consumer receives a message that it cannot decrypt.
consumerEventListener(ConsumerEventListener) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Sets a ConsumerEventListener for the consumer.
ConsumerEventListener - Interface in org.apache.pulsar.client.api: Listener on the consumer state changes.
ConsumerInterceptor<T> - Interface in org.apache.pulsar.client.api: A plugin interface that allows you to intercept (and possibly mutate) messages received by the consumer.
consumerName(String) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Set the consumer name.
ConsumerStats - Interface in org.apache.pulsar.client.api: Consumer statistics recorded by client.
convertKeyValueDataStringToSchemaInfoSchema(byte[]) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation: convert the key/value schema info data json bytes to key/value schema info data bytes
convertKeyValueSchemaInfoDataToString(KeyValue<SchemaInfo, SchemaInfo>) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation: convert the key/value schema data
create(String, String) - Static method in class org.apache.pulsar.client.api.AuthenticationFactory: Create an instance of the Authentication object by using the plugin class name.
create(String, Map<String, String>) - Static method in class org.apache.pulsar.client.api.AuthenticationFactory: Create an instance of the Authentication-Plugin
create() - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Finalize the creation of the Producer instance.
create() - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Finalize the creation of the Reader instance.
createAsync() - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Finalize the creation of the Producer instance in asynchronous mode.
createAsync() - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Finalize the creation of the Reader instance in asynchronous mode.
createAuthentication(String, String) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
createAuthentication(String, Map<String, String>) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
CryptoException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.CryptoException
cryptoFailureAction(ConsumerCryptoFailureAction) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Sets the ConsumerCryptoFailureAction to the value specified
cryptoFailureAction(ProducerCryptoFailureAction) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Sets the ProducerCryptoFailureAction to the value specified
cryptoFailureAction(ConsumerCryptoFailureAction) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Sets the ConsumerCryptoFailureAction to specify
cryptoKeyReader(CryptoKeyReader) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Sets a CryptoKeyReader.
CryptoKeyReader - Interface in org.apache.pulsar.client.api: Interface that abstracts the access to a key store.
cryptoKeyReader(CryptoKeyReader) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Sets a CryptoKeyReader.
cryptoKeyReader(CryptoKeyReader) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Sets a CryptoKeyReader to decrypt the message payloads.

D

DATE - Static variable in interface org.apache.pulsar.client.api.Schema: Date Schema
deadLetterPolicy(DeadLetterPolicy) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Set dead letter policy for consumer By default some message will redelivery so many times possible, even to the extent that it can be never stop.
DeadLetterPolicy - Class in org.apache.pulsar.client.api: Configuration for the "dead letter queue" feature in consumer.
DeadLetterPolicy() - Constructor for class org.apache.pulsar.client.api.DeadLetterPolicy
decode(byte[]) - Method in interface org.apache.pulsar.client.api.Schema: Decode a byte array into an object using the schema definition and deserializer implementation
decode(byte[], byte[]) - Method in interface org.apache.pulsar.client.api.Schema: Decode a byte array into an object using a given version.
decode(byte[], KeyValue.KeyValueDecoder<K, V>) - Static method in class org.apache.pulsar.common.schema.KeyValue: Decode the value into a key/value pair.
decode(byte[], byte[]) - Method in interface org.apache.pulsar.common.schema.KeyValue.KeyValueDecoder: Decode key and value bytes into a KeyValue pair.
decodeKeyValueEncodingType(SchemaInfo) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation: Decode the kv encoding type from the schema info.
decodeKeyValueSchemaInfo(SchemaInfo) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation: Decode the key/value schema info to get key schema info and value schema info.
DEFAULT - Static variable in interface org.apache.pulsar.client.api.BatcherBuilder: Default batch message container incoming single messages: (k1, v1), (k2, v1), (k3, v1), (k1, v2), (k2, v2), (k3, v2), (k1, v3), (k2, v3), (k3, v3) batched into single batch message: [(k1, v1), (k2, v1), (k3, v1), (k1, v2), (k2, v2), (k3, v2), (k1, v3), (k2, v3), (k3, v3)]
DefaultImplementation - Class in org.apache.pulsar.client.internal
DefaultImplementation() - Constructor for class org.apache.pulsar.client.internal.DefaultImplementation
defaultValue(Object) - Method in interface org.apache.pulsar.client.api.schema.FieldSchemaBuilder: Set the default value of this field.
deliverAfter(long, TimeUnit) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Request to deliver the message only after the specified relative delay.
deliverAt(long) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Deliver the message only at or after the specified absolute timestamp.
disableReplication() - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Disable geo-replication for this message.
discard(Exception) - Method in interface org.apache.pulsar.client.api.BatchMessageContainer: Release the payload and clear the container.
doc(String) - Method in interface org.apache.pulsar.client.api.schema.FieldSchemaBuilder: The documentation of this field.
doc(String) - Method in interface org.apache.pulsar.client.api.schema.RecordSchemaBuilder: Add doc to the record schema.
DOUBLE - Static variable in interface org.apache.pulsar.client.api.Schema: Double Schema

E

earliest - Static variable in interface org.apache.pulsar.client.api.MessageId: MessageId that represents the oldest message available in the topic
enableBatching(boolean) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Control whether automatic batching of messages is enabled for the producer.
enableTcpNoDelay(boolean) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Configure whether to use TCP no-delay flag on the connection, to disable Nagle algorithm.
enableTls(boolean) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Deprecated.
use "pulsar+ssl://" in serviceUrl to enable
enableTlsHostnameVerification(boolean) - Method in interface org.apache.pulsar.client.api.ClientBuilder: It allows to validate hostname verification when client connects to broker over tls.
encode(T) - Method in interface org.apache.pulsar.client.api.Schema: Encode an object representing the message content into a byte array.
encode(K, Schema<K>, V, Schema<V>) - Static method in class org.apache.pulsar.common.schema.KeyValue: Encode a key and value pair into a bytes array.
EncodedAuthenticationParameterSupport - Interface in org.apache.pulsar.client.api
encodeKeyValueSchemaInfo(Schema<K>, Schema<V>, KeyValueEncodingType) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation: Encode key & value into schema into a KeyValue schema.
encodeKeyValueSchemaInfo(String, Schema<K>, Schema<V>, KeyValueEncodingType) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation: Encode key & value into schema into a KeyValue schema.
EncryptionContext - Class in org.apache.pulsar.common.api
EncryptionContext() - Constructor for class org.apache.pulsar.common.api.EncryptionContext
EncryptionContext.EncryptionKey - Class in org.apache.pulsar.common.api
EncryptionKey() - Constructor for class org.apache.pulsar.common.api.EncryptionContext.EncryptionKey
EncryptionKeyInfo - Class in org.apache.pulsar.client.api: EncryptionKeyInfo contains the encryption key and corresponding metadata which contains additional information about the key such as version, timestamp.
EncryptionKeyInfo() - Constructor for class org.apache.pulsar.client.api.EncryptionKeyInfo
EncryptionKeyInfo(byte[], Map<String, String>) - Constructor for class org.apache.pulsar.client.api.EncryptionKeyInfo
equals(Object) - Method in class org.apache.pulsar.common.schema.KeyValue
eventTime(long) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Set the event time for a given message.

F

Field - Class in org.apache.pulsar.client.api.schema: A field in a record, consisting of a field name, index, and Schema for the field value.
Field() - Constructor for class org.apache.pulsar.client.api.schema.Field
field(String) - Method in interface org.apache.pulsar.client.api.schema.RecordSchemaBuilder: Add a field with the given name to the record.
field(String, GenericSchema) - Method in interface org.apache.pulsar.client.api.schema.RecordSchemaBuilder: Add a field with the given name and genericSchema to the record.
FieldSchemaBuilder<S extends FieldSchemaBuilder<S>> - Interface in org.apache.pulsar.client.api.schema: Build a field for a record.
FLOAT - Static variable in interface org.apache.pulsar.client.api.Schema: Float Schema
flush() - Method in interface org.apache.pulsar.client.api.Producer: Flush all the messages buffered in the client and wait until all messages have been successfully persisted.
flushAsync() - Method in interface org.apache.pulsar.client.api.Producer: Flush all the messages buffered in the client and wait until all messages have been successfully persisted.
fromByteArray(byte[]) - Static method in interface org.apache.pulsar.client.api.MessageId: De-serialize a message id from a byte array
fromByteArrayWithTopic(byte[], String) - Static method in interface org.apache.pulsar.client.api.MessageId: De-serialize a message id from a byte array with its topic information attached.

G

generic(SchemaInfo) - Static method in interface org.apache.pulsar.client.api.Schema: Returns a generic schema of existing schema info.
GenericRecord - Interface in org.apache.pulsar.client.api.schema: An interface represents a message with schema.
GenericRecordBuilder - Interface in org.apache.pulsar.client.api.schema: Generic Record Builder to build a GenericRecord.
GenericSchema<T extends GenericRecord> - Interface in org.apache.pulsar.client.api.schema: A schema that serializes and deserializes between GenericRecord and bytes.
getAlwaysAllowNull() - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinition: get schema whether always allow null or not
getAuthData() - Method in interface org.apache.pulsar.client.api.Authentication
getAuthData(String) - Method in interface org.apache.pulsar.client.api.Authentication: Get/Create an authentication data provider which provides the data that this client will be sent to the broker.
getAuthMethodName() - Method in interface org.apache.pulsar.client.api.Authentication
getCommandData() - Method in interface org.apache.pulsar.client.api.AuthenticationDataProvider
getConsumerName() - Method in interface org.apache.pulsar.client.api.Consumer: Get the name of consumer.
getCurrentBatchSize() - Method in interface org.apache.pulsar.client.api.BatchMessageContainer: Get current message batch size of the message batch container in bytes.
getData() - Method in interface org.apache.pulsar.client.api.Message: Get the raw payload of the message.
getEncryptionCtx() - Method in interface org.apache.pulsar.client.api.Message: EncryptionContext contains encryption and compression information in it using which application can decrypt consumed message with encrypted-payload.
getEventTime() - Method in interface org.apache.pulsar.client.api.Message: Get the event time associated with this message.
getField(Field) - Method in interface org.apache.pulsar.client.api.schema.GenericRecord: Retrieve the value of the provided field.
getField(String) - Method in interface org.apache.pulsar.client.api.schema.GenericRecord: Retrieve the value of the provided fieldName.
getFields() - Method in interface org.apache.pulsar.client.api.schema.GenericRecord: Returns the list of fields associated with the record.
getFields() - Method in interface org.apache.pulsar.client.api.schema.GenericSchema: Returns the list of fields.
getGenericSchema(SchemaInfo) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
getHttpAuthType() - Method in interface org.apache.pulsar.client.api.AuthenticationDataProvider
getHttpHeaders() - Method in interface org.apache.pulsar.client.api.AuthenticationDataProvider
getJsonDef() - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinition: Get json schema definition
getKey() - Method in class org.apache.pulsar.client.api.EncryptionKeyInfo
getKey() - Method in interface org.apache.pulsar.client.api.Message: Get the key of the message
getKey() - Method in class org.apache.pulsar.common.schema.KeyValue
getKeyBytes() - Method in interface org.apache.pulsar.client.api.Message: Get bytes in key.
getLastMessageId() - Method in interface org.apache.pulsar.client.api.Consumer: Get the last message id available available for consume.
getLastMessageIdAsync() - Method in interface org.apache.pulsar.client.api.Consumer: Get the last message id available available for consume.
getLastSequenceId() - Method in interface org.apache.pulsar.client.api.Producer: Get the last sequence id that was published by this producer.
getLatestSchema() - Method in interface org.apache.pulsar.client.api.schema.SchemaInfoProvider: Retrieve the latest schema info.
getMessageId() - Method in interface org.apache.pulsar.client.api.Message: Get the unique message ID associated with this message.
getMetadata() - Method in class org.apache.pulsar.client.api.EncryptionKeyInfo
getNumAcksFailed() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getNumAcksReceived() - Method in interface org.apache.pulsar.client.api.ProducerStats
getNumAcksSent() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getNumBytesReceived() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getNumBytesSent() - Method in interface org.apache.pulsar.client.api.ProducerStats
getNumMessagesInBatch() - Method in interface org.apache.pulsar.client.api.BatchMessageContainer: Get count of messages in the message batch container.
getNumMsgsReceived() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getNumMsgsSent() - Method in interface org.apache.pulsar.client.api.ProducerStats
getNumReceiveFailed() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getNumSendFailed() - Method in interface org.apache.pulsar.client.api.ProducerStats
getOrderingKey() - Method in interface org.apache.pulsar.client.api.Message: Get the ordering key of the message
getPartitionsForTopic(String) - Method in interface org.apache.pulsar.client.api.PulsarClient: Get the list of partitions for a given topic.
getPojo() - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinition: Get pojo schema definition
getPrivateKey(String, Map<String, String>) - Method in interface org.apache.pulsar.client.api.CryptoKeyReader
getProducerName() - Method in interface org.apache.pulsar.client.api.Message: Get the producer name who produced this message.
getProducerName() - Method in interface org.apache.pulsar.client.api.Producer
getProperties() - Method in interface org.apache.pulsar.client.api.Message: Return the properties attached to the message.
getProperties() - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinition: Get schema class
getProperty(String) - Method in interface org.apache.pulsar.client.api.Message: Get the value of a specific property
getPublicKey(String, Map<String, String>) - Method in interface org.apache.pulsar.client.api.CryptoKeyReader: Return the encryption key corresponding to the key name in the argument
getPublishTime() - Method in interface org.apache.pulsar.client.api.Message: Get the publish time of this message.
getRateBytesReceived() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getRateMsgsReceived() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getRedeliveryCount() - Method in interface org.apache.pulsar.client.api.Message: Get message redelivery count, redelivery count maintain in pulsar broker.
getReplicatedFrom() - Method in interface org.apache.pulsar.client.api.Message: Get name of cluster, from which the message is replicated.
getSchema(SchemaInfo) - Static method in interface org.apache.pulsar.client.api.Schema
getSchema(SchemaInfo) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
getSchemaByVersion(byte[]) - Method in interface org.apache.pulsar.client.api.schema.SchemaInfoProvider: Retrieve the schema info of a given schemaVersion.
getSchemaDefinition() - Method in class org.apache.pulsar.common.schema.SchemaInfo
getSchemaInfo() - Method in interface org.apache.pulsar.client.api.Schema
getSchemaVersion() - Method in interface org.apache.pulsar.client.api.Message: Get schema version of the message.
getSchemaVersion() - Method in interface org.apache.pulsar.client.api.schema.GenericRecord: Return schema version.
getSendBytesRate() - Method in interface org.apache.pulsar.client.api.ProducerStats
getSendLatencyMillis50pct() - Method in interface org.apache.pulsar.client.api.ProducerStats
getSendLatencyMillis75pct() - Method in interface org.apache.pulsar.client.api.ProducerStats
getSendLatencyMillis95pct() - Method in interface org.apache.pulsar.client.api.ProducerStats
getSendLatencyMillis999pct() - Method in interface org.apache.pulsar.client.api.ProducerStats
getSendLatencyMillis99pct() - Method in interface org.apache.pulsar.client.api.ProducerStats
getSendLatencyMillisMax() - Method in interface org.apache.pulsar.client.api.ProducerStats
getSendMsgsRate() - Method in interface org.apache.pulsar.client.api.ProducerStats
getSequenceId() - Method in interface org.apache.pulsar.client.api.Message: Get the sequence id associated with this message.
getServiceUrl() - Method in interface org.apache.pulsar.client.api.ServiceUrlProvider: Get the current service URL the Pulsar client should connect to.
getStats() - Method in interface org.apache.pulsar.client.api.Consumer: Get statistics for the consumer.
getStats() - Method in interface org.apache.pulsar.client.api.Producer: Get statistics for the producer numMsgsSent : Number of messages sent in the current interval numBytesSent : Number of bytes sent in the current interval numSendFailed : Number of messages failed to send in the current interval numAcksReceived : Number of acks received in the current interval totalMsgsSent : Total number of messages sent totalBytesSent : Total number of bytes sent totalSendFailed : Total number of messages failed to send totalAcksReceived: Total number of acks received
getSubscription() - Method in interface org.apache.pulsar.client.api.Consumer: Get a subscription for the consumer
getSupportSchemaVersioning() - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinition: Get supportSchemaVersioning schema definition
GettingAuthenticationDataException(Throwable) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.GettingAuthenticationDataException
GettingAuthenticationDataException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.GettingAuthenticationDataException
getTlsCertificates() - Method in interface org.apache.pulsar.client.api.AuthenticationDataProvider
getTlsPrivateKey() - Method in interface org.apache.pulsar.client.api.AuthenticationDataProvider
getTopic() - Method in interface org.apache.pulsar.client.api.Consumer: Get a topic for the consumer
getTopic() - Method in interface org.apache.pulsar.client.api.Producer
getTopic() - Method in interface org.apache.pulsar.client.api.Reader
getTopicName() - Method in interface org.apache.pulsar.client.api.Message: Get the topic the message was published to
getTopicName() - Method in interface org.apache.pulsar.client.api.schema.SchemaInfoProvider: Retrieve the topic name.
getTotalAcksFailed() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getTotalAcksReceived() - Method in interface org.apache.pulsar.client.api.ProducerStats
getTotalAcksSent() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getTotalBytesReceived() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getTotalBytesSent() - Method in interface org.apache.pulsar.client.api.ProducerStats
getTotalMsgsReceived() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getTotalMsgsSent() - Method in interface org.apache.pulsar.client.api.ProducerStats
getTotalReceivedFailed() - Method in interface org.apache.pulsar.client.api.ConsumerStats
getTotalSendFailed() - Method in interface org.apache.pulsar.client.api.ProducerStats
getValue() - Method in interface org.apache.pulsar.client.api.Message: Get the de-serialized value of the message, according the configured Schema.
getValue() - Method in enum org.apache.pulsar.client.api.SubscriptionInitialPosition
getValue() - Method in class org.apache.pulsar.common.schema.KeyValue
getValue() - Method in enum org.apache.pulsar.common.schema.SchemaType

H

hasBase64EncodedKey() - Method in interface org.apache.pulsar.client.api.Message: Check whether the key has been base64 encoded.
hasDataForHttp() - Method in interface org.apache.pulsar.client.api.AuthenticationDataProvider: Check if data for HTTP are available.
hasDataForTls() - Method in interface org.apache.pulsar.client.api.AuthenticationDataProvider: Check if data for TLS are available.
hasDataFromCommand() - Method in interface org.apache.pulsar.client.api.AuthenticationDataProvider: Check if data from Pulsar protocol are available.
hashCode() - Method in class org.apache.pulsar.common.schema.KeyValue
HashingScheme - Enum in org.apache.pulsar.client.api: Standard hashing functions available when choosing the partition to use for a particular message.
hashingScheme(HashingScheme) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Change the HashingScheme used to chose the partition on where to publish a particular message.
hasKey() - Method in interface org.apache.pulsar.client.api.Message: Check whether the message has a key
hasMessageAvailable() - Method in interface org.apache.pulsar.client.api.Reader: Check if there is any message available to read from the current position.
hasMessageAvailableAsync() - Method in interface org.apache.pulsar.client.api.Reader: Asynchronously check if there is any message available to read from the current position.
hasOrderingKey() - Method in interface org.apache.pulsar.client.api.Message: Check whether the message has a ordering key
hasProperty(String) - Method in interface org.apache.pulsar.client.api.Message: Check whether the message has a specific property attached.
hasReachedEndOfTopic() - Method in interface org.apache.pulsar.client.api.Consumer: Return true if the topic was terminated and this consumer has already consumed all the messages in the topic.
hasReachedEndOfTopic() - Method in interface org.apache.pulsar.client.api.Reader: Return true if the topic was terminated and this reader has reached the end of the topic.

I

IncompatibleSchemaException(Throwable) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.IncompatibleSchemaException
IncompatibleSchemaException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.IncompatibleSchemaException
INIT_AUTH_DATA - Static variable in class org.apache.pulsar.common.api.AuthData
initialize(PulsarClient) - Method in interface org.apache.pulsar.client.api.ServiceUrlProvider: Initialize the service url provider with Pulsar client instance.
initialSequenceId(long) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set the baseline for the sequence ids for messages published by the producer.
INT16 - Static variable in interface org.apache.pulsar.client.api.Schema: INT16 Schema
INT32 - Static variable in interface org.apache.pulsar.client.api.Schema: INT32 Schema
INT64 - Static variable in interface org.apache.pulsar.client.api.Schema: INT64 Schema
INT8 - Static variable in interface org.apache.pulsar.client.api.Schema: INT8 Schema
intercept(ConsumerInterceptor<T>...) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Intercept Consumer.
intercept(ProducerInterceptor<T>...) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Add a set of ProducerInterceptor to the producer.
InvalidConfigurationException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.InvalidConfigurationException
InvalidConfigurationException(Throwable) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.InvalidConfigurationException
InvalidMessageException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.InvalidMessageException
InvalidServiceURL(Throwable) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.InvalidServiceURL
InvalidTopicNameException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.InvalidTopicNameException
ioThreads(int) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set the number of threads to be used for handling connections to brokers (default: 1 thread)
isComplete() - Method in class org.apache.pulsar.common.api.AuthData
isConnected() - Method in interface org.apache.pulsar.client.api.Consumer
isConnected() - Method in interface org.apache.pulsar.client.api.Producer
isConnected() - Method in interface org.apache.pulsar.client.api.Reader
isEmpty() - Method in interface org.apache.pulsar.client.api.BatchMessageContainer: Check the message batch container is empty.
isMultiBatches() - Method in interface org.apache.pulsar.client.api.BatchMessageContainer: Return the batch container batch message in multiple batches
isPrimitive() - Method in enum org.apache.pulsar.common.schema.SchemaType
isPrimitiveType(SchemaType) - Static method in enum org.apache.pulsar.common.schema.SchemaType
isReplicated() - Method in interface org.apache.pulsar.client.api.Message: Check whether the message is replicated from other cluster.
isStruct() - Method in enum org.apache.pulsar.common.schema.SchemaType
isStructType(SchemaType) - Static method in enum org.apache.pulsar.common.schema.SchemaType

J

JSON(Class<T>) - Static method in interface org.apache.pulsar.client.api.Schema: Create a JSON schema type by extracting the fields of the specified class.
JSON(SchemaDefinition) - Static method in interface org.apache.pulsar.client.api.Schema: Create a JSON schema type with schema definition
jsonifyKeyValueSchemaInfo(KeyValue<SchemaInfo, SchemaInfo>) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation: Jsonify the key/value schema info.
jsonifySchemaInfo(SchemaInfo) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation: Jsonify the schema info.
jsonifySchemaInfoWithVersion(SchemaInfoWithVersion) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation: Jsonify the schema info with version.

K

keepAliveInterval(int, TimeUnit) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set keep alive interval for each client-broker-connection.
key(String) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Sets the key of the message for routing policy
KEY_BASED - Static variable in interface org.apache.pulsar.client.api.BatcherBuilder: Key based batch message container incoming single messages: (k1, v1), (k2, v1), (k3, v1), (k1, v2), (k2, v2), (k3, v2), (k1, v3), (k2, v3), (k3, v3) batched into multiple batch messages: [(k1, v1), (k1, v2), (k1, v3)], [(k2, v1), (k2, v2), (k2, v3)], [(k3, v1), (k3, v2), (k3, v3)]
keyBytes(byte[]) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Sets the bytes of the key of the message for routing policy.
KeyValue(Class<K>, Class<V>, SchemaType) - Static method in interface org.apache.pulsar.client.api.Schema: Key Value Schema using passed in schema type, support JSON and AVRO currently.
KeyValue(Class<K>, Class<V>) - Static method in interface org.apache.pulsar.client.api.Schema: Key Value Schema whose underneath key and value schemas are JSONSchema.
KeyValue(Schema<K>, Schema<V>) - Static method in interface org.apache.pulsar.client.api.Schema: Key Value Schema using passed in key and value schemas.
KeyValue(Schema<K>, Schema<V>, KeyValueEncodingType) - Static method in interface org.apache.pulsar.client.api.Schema: Key Value Schema using passed in key, value and encoding type schemas.
KeyValue<K,V> - Class in org.apache.pulsar.common.schema: A simple KeyValue class
KeyValue(K, V) - Constructor for class org.apache.pulsar.common.schema.KeyValue
KeyValue.KeyValueDecoder<K,V> - Interface in org.apache.pulsar.common.schema: Decoder to decode key/value bytes.
KeyValueEncodingType - Enum in org.apache.pulsar.common.schema: Encoding types of supported KeyValueSchema for Pulsar messages
KV_BYTES() - Static method in interface org.apache.pulsar.client.api.Schema: Schema that can be used to encode/decode KeyValue.

L

latest - Static variable in interface org.apache.pulsar.client.api.MessageId: MessageId that represents the next message published in the topic
listenerThreads(int) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set the number of threads to be used for message listeners (default: 1 thread).
loadConf(Map<String, Object>) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Load the configuration from provided config map.
loadConf(Map<String, Object>) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Load the configuration from provided config map.
loadConf(Map<String, Object>) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Load the configuration from provided config map.
loadConf(Map<String, Object>) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Load the configuration from provided config map.
loadConf(Map<String, Object>) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Configure the TypedMessageBuilder from a config map, as an alternative compared to call the individual builder methods.
LookupException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.LookupException

M

maxBackoffInterval(long, TimeUnit) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set the maximum duration of time for a backoff interval.
maxConcurrentLookupRequests(int) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Number of concurrent lookup-requests allowed to send on each broker-connection to prevent overload on broker.
maxLookupRequests(int) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Number of max lookup-requests allowed on each broker-connection to prevent overload on broker.
maxNumberOfRejectedRequestPerConnection(int) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set max number of broker-rejected requests in a certain time-frame (30 seconds) after which current connection will be closed and client creates a new connection that give chance to connect a different broker (default: 50)
maxPendingMessages(int) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set the max size of the queue holding the messages pending to receive an acknowledgment from the broker.
maxPendingMessagesAcrossPartitions(int) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set the number of max pending messages across all the partitions
maxTotalReceiverQueueSizeAcrossPartitions(int) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Set the max total receiver queue size across partitons.
Message<T> - Interface in org.apache.pulsar.client.api: The message abstraction used in Pulsar.
MessageId - Interface in org.apache.pulsar.client.api: Opaque unique identifier of a single message
messageListener(MessageListener<T>) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Sets a MessageListener for the consumer
MessageListener<T> - Interface in org.apache.pulsar.client.api: A listener that will be called in order for every message received.
MessageRouter - Interface in org.apache.pulsar.client.api: Interface for custom message router that can be passed to a producer to select the partition that a particular messsage should be published on.
messageRouter(MessageRouter) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set a custom message routing policy by passing an implementation of MessageRouter.
MessageRoutingMode - Enum in org.apache.pulsar.client.api: Default routing mode for messages to partition.
messageRoutingMode(MessageRoutingMode) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set the MessageRoutingMode for a partitioned producer.

N

negativeAcknowledge(Message<?>) - Method in interface org.apache.pulsar.client.api.Consumer: Acknowledge the failure to process a single message.
negativeAcknowledge(MessageId) - Method in interface org.apache.pulsar.client.api.Consumer: Acknowledge the failure to process a single message.
negativeAckRedeliveryDelay(long, TimeUnit) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Set the delay to wait before re-delivering messages that have failed to be process.
newAuthenticationTLS(String, String) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newAuthenticationToken(String) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newAuthenticationToken(Supplier<String>) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newAutoConsumeSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newAutoProduceSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newAvroSchema(SchemaDefinition) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newBooleanSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newByteBufferSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newByteSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newBytesSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newClientBuilder() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newConsumer() - Method in interface org.apache.pulsar.client.api.PulsarClient: Create a consumer builder with no schema (Schema.BYTES) for subscribing to one or more topics.
newConsumer(Schema<T>) - Method in interface org.apache.pulsar.client.api.PulsarClient: Create a consumer builder with a specific schema for subscribing on a specific topic
newDateSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newDefaultBatcherBuilder() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newDoubleSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newFloatSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newIntSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newJSONSchema(SchemaDefinition) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newKeyBasedBatcherBuilder() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newKeyValueBytesSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newKeyValueSchema(Schema<K>, Schema<V>) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newKeyValueSchema(Schema<K>, Schema<V>, KeyValueEncodingType) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newKeyValueSchema(Class<K>, Class<V>, SchemaType) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newLongSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newMessage() - Method in interface org.apache.pulsar.client.api.Producer: Create a new message builder This message builder allows to specify additional properties on the message.
newMessageId(long, long, int) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newMessageIdFromByteArray(byte[]) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newMessageIdFromByteArrayWithTopic(byte[], String) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newProducer() - Method in interface org.apache.pulsar.client.api.PulsarClient: Create a producer builder that can be used to configure and construct a producer with default Schema.BYTES.
newProducer(Schema<T>) - Method in interface org.apache.pulsar.client.api.PulsarClient: Create a producer builder that can be used to configure and construct a producer with the specified schema
newProtobufSchema(SchemaDefinition) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newReader() - Method in interface org.apache.pulsar.client.api.PulsarClient: Create a topic reader builder with no schema (Schema.BYTES) to read from the specified topic.
newReader(Schema<T>) - Method in interface org.apache.pulsar.client.api.PulsarClient: Create a topic reader builder with a specific Schema) to read from the specified topic.
newRecordBuilder() - Method in interface org.apache.pulsar.client.api.schema.GenericSchema: Create a builder to build GenericRecord.
newRecordSchemaBuilder(String) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newRequestHeader(String, AuthenticationDataProvider, Map<String, String>) - Method in interface org.apache.pulsar.client.api.Authentication: Add an authenticationStage that will complete along with authFuture
newSchemaDefinitionBuilder() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newShortSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newStringSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newStringSchema(Charset) - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newTimeSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
newTimestampSchema() - Static method in class org.apache.pulsar.client.internal.DefaultImplementation
NotConnectedException() - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.NotConnectedException
NotFoundException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.NotFoundException
NotFoundException(Throwable) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.NotFoundException
NotSupportedException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.NotSupportedException
numPartitions() - Method in interface org.apache.pulsar.client.api.TopicMetadata: Return the number of partitions per topic.

O

onAcknowledge(Consumer<T>, MessageId, Throwable) - Method in interface org.apache.pulsar.client.api.ConsumerInterceptor: This is called consumer sends the acknowledgment to the broker.
onAcknowledgeCumulative(Consumer<T>, MessageId, Throwable) - Method in interface org.apache.pulsar.client.api.ConsumerInterceptor: This is called consumer send the cumulative acknowledgment to the broker.
onAckTimeoutSend(Consumer<T>, Set<MessageId>) - Method in interface org.apache.pulsar.client.api.ConsumerInterceptor: This method will be called when a redelivery from an acknowledge timeout occurs.
onNegativeAcksSend(Consumer<T>, Set<MessageId>) - Method in interface org.apache.pulsar.client.api.ConsumerInterceptor: This method will be called when a redelivery from a negative acknowledge occurs.
onSendAcknowledgement(Producer<T>, Message<T>, MessageId, Throwable) - Method in interface org.apache.pulsar.client.api.ProducerInterceptor: This method is called when the message sent to the broker has been acknowledged, or when sending the message fails.
operationTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set the operation timeout (default: 30 seconds)
optional() - Method in interface org.apache.pulsar.client.api.schema.FieldSchemaBuilder: Make this field optional.
orderingKey(byte[]) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Sets the ordering key of the message for message dispatch in SubscriptionType.Key_Shared mode.
org.apache.pulsar.client.api - package org.apache.pulsar.client.api
org.apache.pulsar.client.api.schema - package org.apache.pulsar.client.api.schema
org.apache.pulsar.client.internal - package org.apache.pulsar.client.internal
org.apache.pulsar.common.api - package org.apache.pulsar.common.api
org.apache.pulsar.common.schema - package org.apache.pulsar.common.schema

P

patternAutoDiscoveryPeriod(int) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Set topics auto discovery period when using a pattern for topics consumer.
pause() - Method in interface org.apache.pulsar.client.api.Consumer: Stop requesting new messages from the broker until Consumer.resume() is called.
priorityLevel(int) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Shared subscription Sets priority level for the shared subscription consumers to which broker gives more priority while dispatching messages.
Producer<T> - Interface in org.apache.pulsar.client.api: Producer is used to publish messages on a topic.
ProducerBlockedQuotaExceededError(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.ProducerBlockedQuotaExceededError
ProducerBlockedQuotaExceededException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.ProducerBlockedQuotaExceededException
ProducerBuilder<T> - Interface in org.apache.pulsar.client.api: ProducerBuilder is used to configure and create instances of Producer.
ProducerBusyException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.ProducerBusyException
ProducerCryptoFailureAction - Enum in org.apache.pulsar.client.api: The action the producer will take in case of encryption failures
ProducerInterceptor<T> - Interface in org.apache.pulsar.client.api: A plugin interface that allows you to intercept (and possibly mutate) the messages received by the producer before they are published to the Pulsar brokers.
producerName(String) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Specify a name for the producer
ProducerQueueIsFullError(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.ProducerQueueIsFullError
ProducerStats - Interface in org.apache.pulsar.client.api: Producer statistics recorded by client.
properties(Map<String, String>) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Add all the properties in the provided map to the consumer.
properties(Map<String, String>) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Add all the properties in the provided map to the producer.
properties(Map<String, String>) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Add all the properties in the provided map
property(String, String) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Set a name/value property with this consumer.
property(String, String) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set a name/value property with this producer.
property(String, String) - Method in interface org.apache.pulsar.client.api.schema.FieldSchemaBuilder: Set name-value pair properties for this field.
property(String, String) - Method in interface org.apache.pulsar.client.api.schema.RecordSchemaBuilder: Attach val-name property pair to the record schema.
property(String, String) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Sets a new property on a message.
PROTOBUF(Class<T>) - Static method in interface org.apache.pulsar.client.api.Schema: Create a Protobuf schema type by extracting the fields of the specified class.
PROTOBUF(SchemaDefinition<T>) - Static method in interface org.apache.pulsar.client.api.Schema: Create a Protobuf schema type with schema definition.
PulsarClient - Interface in org.apache.pulsar.client.api: Class that provides a client interface to Pulsar.
PulsarClientException - Exception in org.apache.pulsar.client.api: Base type of exception thrown by Pulsar client
PulsarClientException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException
PulsarClientException(Throwable) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException
PulsarClientException.AlreadyClosedException - Exception in org.apache.pulsar.client.api
PulsarClientException.AuthenticationException - Exception in org.apache.pulsar.client.api
PulsarClientException.AuthorizationException - Exception in org.apache.pulsar.client.api
PulsarClientException.BrokerMetadataException - Exception in org.apache.pulsar.client.api
PulsarClientException.BrokerPersistenceException - Exception in org.apache.pulsar.client.api
PulsarClientException.ChecksumException - Exception in org.apache.pulsar.client.api
PulsarClientException.ConnectException - Exception in org.apache.pulsar.client.api
PulsarClientException.ConsumerBusyException - Exception in org.apache.pulsar.client.api
PulsarClientException.CryptoException - Exception in org.apache.pulsar.client.api
PulsarClientException.GettingAuthenticationDataException - Exception in org.apache.pulsar.client.api
PulsarClientException.IncompatibleSchemaException - Exception in org.apache.pulsar.client.api
PulsarClientException.InvalidConfigurationException - Exception in org.apache.pulsar.client.api
PulsarClientException.InvalidMessageException - Exception in org.apache.pulsar.client.api
PulsarClientException.InvalidServiceURL - Exception in org.apache.pulsar.client.api
PulsarClientException.InvalidTopicNameException - Exception in org.apache.pulsar.client.api
PulsarClientException.LookupException - Exception in org.apache.pulsar.client.api
PulsarClientException.NotConnectedException - Exception in org.apache.pulsar.client.api
PulsarClientException.NotFoundException - Exception in org.apache.pulsar.client.api
PulsarClientException.NotSupportedException - Exception in org.apache.pulsar.client.api
PulsarClientException.ProducerBlockedQuotaExceededError - Exception in org.apache.pulsar.client.api
PulsarClientException.ProducerBlockedQuotaExceededException - Exception in org.apache.pulsar.client.api
PulsarClientException.ProducerBusyException - Exception in org.apache.pulsar.client.api
PulsarClientException.ProducerQueueIsFullError - Exception in org.apache.pulsar.client.api
PulsarClientException.TimeoutException - Exception in org.apache.pulsar.client.api
PulsarClientException.TooManyRequestsException - Exception in org.apache.pulsar.client.api
PulsarClientException.TopicTerminatedException - Exception in org.apache.pulsar.client.api
PulsarClientException.UnsupportedAuthenticationException - Exception in org.apache.pulsar.client.api

R

reachedEndOfTopic(Consumer<T>) - Method in interface org.apache.pulsar.client.api.MessageListener: Get the notification when a topic is terminated
reachedEndOfTopic(Reader<T>) - Method in interface org.apache.pulsar.client.api.ReaderListener: Get the notification when a topic is terminated
read(byte[]) - Method in interface org.apache.pulsar.client.api.schema.SchemaReader: serialize bytes convert pojo
readCompacted(boolean) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: If enabled, the consumer will read messages from the compacted topic rather than reading the full message backlog of the topic.
readCompacted(boolean) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: If enabled, the reader will read messages from the compacted topic rather than reading the full message backlog of the topic.
Reader<T> - Interface in org.apache.pulsar.client.api: A Reader can be used to scan through all the messages currently available in a topic.
ReaderBuilder<T> - Interface in org.apache.pulsar.client.api: ReaderBuilder is used to configure and create instances of Reader.
readerListener(ReaderListener<T>) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Sets a ReaderListener for the reader
ReaderListener<T> - Interface in org.apache.pulsar.client.api: A listener that will be called in order for every message received.
readerName(String) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Specify a reader name.
readNext() - Method in interface org.apache.pulsar.client.api.Reader: Read the next message in the topic.
readNext(int, TimeUnit) - Method in interface org.apache.pulsar.client.api.Reader: Read the next message in the topic waiting for a maximum time.
readNextAsync() - Method in interface org.apache.pulsar.client.api.Reader: Read asynchronously the next message in the topic.
receive() - Method in interface org.apache.pulsar.client.api.Consumer: Receives a single message.
receive(int, TimeUnit) - Method in interface org.apache.pulsar.client.api.Consumer: Receive a single message
receiveAsync() - Method in interface org.apache.pulsar.client.api.Consumer: Receive a single message
received(Consumer<T>, Message<T>) - Method in interface org.apache.pulsar.client.api.MessageListener: This method is called whenever a new message is received.
received(Reader<T>, Message<T>) - Method in interface org.apache.pulsar.client.api.ReaderListener: This method is called whenever a new message is received.
receiverQueueSize(int) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Sets the size of the consumer receive queue.
receiverQueueSize(int) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Sets the size of the consumer receive queue.
record(String) - Static method in interface org.apache.pulsar.client.api.schema.SchemaBuilder: Build the schema for a record.
RecordSchemaBuilder - Interface in org.apache.pulsar.client.api.schema: Building the schema for a GenericRecord.
redeliverUnacknowledgedMessages() - Method in interface org.apache.pulsar.client.api.Consumer: Redelivers all the unacknowledged messages.
RegexSubscriptionMode - Enum in org.apache.pulsar.client.api: When subscribing to topics using a regular expression, one can specify to only pick a certain type of topics.
replicateSubscriptionState(boolean) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder
replicationClusters(List<String>) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Override the geo-replication clusters for this message.
required() - Method in interface org.apache.pulsar.client.api.schema.FieldSchemaBuilder: Make this field required.
requireFetchingSchemaInfo() - Method in interface org.apache.pulsar.client.api.Schema: Check if this schema requires fetching schema info to configure the schema.
resume() - Method in interface org.apache.pulsar.client.api.Consumer: Resume requesting messages from the broker.

S

Schema<T> - Interface in org.apache.pulsar.client.api: Message schema definition
SchemaBuilder - Interface in org.apache.pulsar.client.api.schema: Builder to build schema.
SchemaDefinition<T> - Interface in org.apache.pulsar.client.api.schema
SchemaDefinitionBuilder<T> - Interface in org.apache.pulsar.client.api.schema: Builder to build schema definition SchemaDefinition.
SchemaInfo - Class in org.apache.pulsar.common.schema
SchemaInfo() - Constructor for class org.apache.pulsar.common.schema.SchemaInfo
SchemaInfoProvider - Interface in org.apache.pulsar.client.api.schema: Schema Provider.
SchemaInfoWithVersion - Class in org.apache.pulsar.common.schema
SchemaInfoWithVersion() - Constructor for class org.apache.pulsar.common.schema.SchemaInfoWithVersion
SchemaReader<T> - Interface in org.apache.pulsar.client.api.schema
SchemaSerializationException - Exception in org.apache.pulsar.client.api
SchemaSerializationException(String) - Constructor for exception org.apache.pulsar.client.api.SchemaSerializationException
SchemaSerializationException(Throwable) - Constructor for exception org.apache.pulsar.client.api.SchemaSerializationException
SchemaType - Enum in org.apache.pulsar.common.schema: Types of supported schema for Pulsar messages
SchemaWriter<T> - Interface in org.apache.pulsar.client.api.schema: Serialize messages into bytes.
seek(MessageId) - Method in interface org.apache.pulsar.client.api.Consumer: Reset the subscription associated with this consumer to a specific message id.
seek(long) - Method in interface org.apache.pulsar.client.api.Consumer: Reset the subscription associated with this consumer to a specific message publish time.
seek(MessageId) - Method in interface org.apache.pulsar.client.api.Reader: Reset the subscription associated with this reader to a specific message id.
seek(long) - Method in interface org.apache.pulsar.client.api.Reader: Reset the subscription associated with this reader to a specific message publish time.
seekAsync(MessageId) - Method in interface org.apache.pulsar.client.api.Consumer: Reset the subscription associated with this consumer to a specific message id.
seekAsync(long) - Method in interface org.apache.pulsar.client.api.Consumer: Reset the subscription associated with this consumer to a specific message publish time.
seekAsync(MessageId) - Method in interface org.apache.pulsar.client.api.Reader: Reset the subscription associated with this reader to a specific message id.
seekAsync(long) - Method in interface org.apache.pulsar.client.api.Reader: Reset the subscription associated with this reader to a specific message publish time.
send(T) - Method in interface org.apache.pulsar.client.api.Producer: Sends a message.
send() - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Send a message synchronously.
sendAsync(T) - Method in interface org.apache.pulsar.client.api.Producer: Send a message asynchronously
sendAsync() - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Send a message asynchronously
sendTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Set the send timeout (default: 30 seconds)
sequenceId(long) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Specify a custom sequence id for the message being published.
serviceUrl(String) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Configure the service URL for the Pulsar service.
serviceUrlProvider(ServiceUrlProvider) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Configure the service URL provider for Pulsar service
ServiceUrlProvider - Interface in org.apache.pulsar.client.api: The provider to provide the service url.
set(String, Object) - Method in interface org.apache.pulsar.client.api.schema.GenericRecordBuilder: Sets the value of a field.
set(Field, Object) - Method in interface org.apache.pulsar.client.api.schema.GenericRecordBuilder: Sets the value of a field.
setKey(byte[]) - Method in class org.apache.pulsar.client.api.EncryptionKeyInfo
setMetadata(Map<String, String>) - Method in class org.apache.pulsar.client.api.EncryptionKeyInfo
setSchemaInfoProvider(SchemaInfoProvider) - Method in interface org.apache.pulsar.client.api.Schema
shutdown() - Method in interface org.apache.pulsar.client.api.PulsarClient: Perform immediate shutdown of PulsarClient.
start() - Method in interface org.apache.pulsar.client.api.Authentication: Initialize the authentication provider
startingBackoffInterval(long, TimeUnit) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set the duration of time for a backoff interval.
startMessageId(MessageId) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: The initial reader positioning is done by specifying a message id.
startMessageIdInclusive() - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Set the reader to include the given position of ReaderBuilder.startMessageId(MessageId)
statsInterval(long, TimeUnit) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set the interval between each stat info (default: 60 seconds) Stats will be activated with positive statsInterval It should be set to at least 1 second
STRING - Static variable in interface org.apache.pulsar.client.api.Schema: Schema that can be used to encode/decode messages whose values are String.
subscribe() - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Finalize the Consumer creation by subscribing to the topic.
subscribeAsync() - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Finalize the Consumer creation by subscribing to the topic in asynchronous mode.
subscriptionInitialPosition(SubscriptionInitialPosition) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Set the SubscriptionInitialPosition for the consumer.
SubscriptionInitialPosition - Enum in org.apache.pulsar.client.api: When creating a consumer, if the subscription does not exist, a new subscription will be created.
subscriptionName(String) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Specify the subscription name for this consumer.
subscriptionRolePrefix(String) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Set the subscription role prefix.
subscriptionTopicsMode(RegexSubscriptionMode) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Determines to which topics this consumer should be subscribed to - Persistent, Non-Persistent, or both.
subscriptionType(SubscriptionType) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Select the subscription type to be used when subscribing to the topic.
SubscriptionType - Enum in org.apache.pulsar.client.api: Types of subscription supported by Pulsar
supportSchemaVersioning() - Method in interface org.apache.pulsar.client.api.Schema: Returns whether this schema supports versioning.

T

TIME - Static variable in interface org.apache.pulsar.client.api.Schema: Time Schema
TimeoutException(Throwable) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.TimeoutException
TimeoutException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.TimeoutException
TIMESTAMP - Static variable in interface org.apache.pulsar.client.api.Schema: Timestamp Schema
TLS(String, String) - Static method in class org.apache.pulsar.client.api.AuthenticationFactory: Create an authentication provider for TLS based authentication.
tlsTrustCertsFilePath(String) - Method in interface org.apache.pulsar.client.api.ClientBuilder: Set the path to the trusted TLS certificate file
toByteArray() - Method in interface org.apache.pulsar.client.api.MessageId: Serialize the message ID into a byte array.
token(String) - Static method in class org.apache.pulsar.client.api.AuthenticationFactory: Create an authentication provider for token based authentication.
token(Supplier<String>) - Static method in class org.apache.pulsar.client.api.AuthenticationFactory: Create an authentication provider for token based authentication.
TooManyRequestsException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.TooManyRequestsException
topic(String...) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Specify the topics this consumer will subscribe on.
topic(String) - Method in interface org.apache.pulsar.client.api.ProducerBuilder: Specify the topic this producer will be publishing on.
topic(String) - Method in interface org.apache.pulsar.client.api.ReaderBuilder: Specify the topic this reader will read from.
TopicMetadata - Interface in org.apache.pulsar.client.api: Metadata of a topic that can be used for message routing.
topics(List<String>) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Specify a list of topics that this consumer will subscribe on.
topicsPattern(Pattern) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Specify a pattern for topics that this consumer will subscribe on.
topicsPattern(String) - Method in interface org.apache.pulsar.client.api.ConsumerBuilder: Specify a pattern for topics that this consumer will subscribe on.
TopicTerminatedException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.TopicTerminatedException
toString() - Method in class org.apache.pulsar.common.schema.KeyValue
toString() - Method in class org.apache.pulsar.common.schema.SchemaInfo
toString() - Method in class org.apache.pulsar.common.schema.SchemaInfoWithVersion
type(SchemaType) - Method in interface org.apache.pulsar.client.api.schema.FieldSchemaBuilder: The type of this field.
TypedMessageBuilder<T> - Interface in org.apache.pulsar.client.api: Message builder that constructs a message to be published through a producer.

U

unsubscribe() - Method in interface org.apache.pulsar.client.api.Consumer: Unsubscribe the consumer
unsubscribeAsync() - Method in interface org.apache.pulsar.client.api.Consumer: Asynchronously unsubscribe the consumer
UnsupportedAuthenticationException(Throwable) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.UnsupportedAuthenticationException
UnsupportedAuthenticationException(String) - Constructor for exception org.apache.pulsar.client.api.PulsarClientException.UnsupportedAuthenticationException
unwrap(Throwable) - Static method in exception org.apache.pulsar.client.api.PulsarClientException
updateServiceUrl(String) - Method in interface org.apache.pulsar.client.api.PulsarClient: Update the service URL this client is using.

V

validate(byte[]) - Method in interface org.apache.pulsar.client.api.Schema: Check if the message is a valid object for this schema.
value(T) - Method in interface org.apache.pulsar.client.api.TypedMessageBuilder: Set a domain object on the message
valueOf(String) - Static method in enum org.apache.pulsar.client.api.CompressionType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.client.api.ConsumerCryptoFailureAction: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.client.api.HashingScheme: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.client.api.MessageRoutingMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.client.api.ProducerCryptoFailureAction: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.client.api.RegexSubscriptionMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.client.api.SubscriptionInitialPosition: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.client.api.SubscriptionType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.common.schema.KeyValueEncodingType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.common.schema.SchemaType: Returns the enum constant of this type with the specified name.
valueOf(int) - Static method in enum org.apache.pulsar.common.schema.SchemaType
values() - Static method in enum org.apache.pulsar.client.api.CompressionType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.client.api.ConsumerCryptoFailureAction: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.client.api.HashingScheme: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.client.api.MessageRoutingMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.client.api.ProducerCryptoFailureAction: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.client.api.RegexSubscriptionMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.client.api.SubscriptionInitialPosition: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.client.api.SubscriptionType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.common.schema.KeyValueEncodingType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.common.schema.SchemaType: Returns an array containing the constants of this enum type, in the order they are declared.

W

withAlwaysAllowNull(boolean) - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinitionBuilder: Set schema whether always allow null or not
withJsonDef(String) - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinitionBuilder: Set schema of json definition
withPojo(Class) - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinitionBuilder: Set schema of pojo definition
withProperties(Map<String, String>) - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinitionBuilder: Set schema info properties
withSupportSchemaVersioning(boolean) - Method in interface org.apache.pulsar.client.api.schema.SchemaDefinitionBuilder: Set schema whether decode by schema version
write(T) - Method in interface org.apache.pulsar.client.api.schema.SchemaWriter: serialize the message into bytes

A B C D E F G H I J K L M N O P R S T U V W