static class
Already closed exception thrown by Pulsar client.
static class
Authentication exception thrown by Pulsar client.
static class
Authorization exception thrown by Pulsar client.
static class
Broker metadata exception thrown by Pulsar client.
static class
Broker persistence exception thrown by Pulsar client.
static class
Checksum exception thrown by Pulsar client.
static class
Connect exception thrown by Pulsar client.
static class
Consumer assign exception thrown by Pulsar client.
static class
Consumer busy exception thrown by Pulsar client.
static class
Crypto exception thrown by Pulsar client.
static class
Getting authentication data exception thrown by Pulsar client.
static class
Incompatible schema exception thrown by Pulsar client.
static class
Invalid Configuration exception thrown by Pulsar client.
static class
Invalid message exception thrown by Pulsar client.
static class
Invalid Service URL exception thrown by Pulsar client.
static class
Invalid topic name exception thrown by Pulsar client.
static class
Lookup exception thrown by Pulsar client.
static class
Memory buffer full error thrown by Pulsar client.
static class
Consumer assign exception thrown by Pulsar client.
static class
Not allowed exception thrown by Pulsar client.
static class
Not connected exception thrown by Pulsar client.
static class
Not Found exception thrown by Pulsar client.
static class
Not supported exception thrown by Pulsar client.
static class
Producer blocked quota exceeded error thrown by Pulsar client.
static class
Producer blocked quota exceeded exception thrown by Pulsar client.
static class
Producer busy exception thrown by Pulsar client.
static class
Producer fenced exception thrown by Pulsar client.
static class
Full producer queue error thrown by Pulsar client.
static class
Timeout exception thrown by Pulsar client.
static class
Too many requests exception thrown by Pulsar client.
static class
Topic does not exist and cannot be created.
static class
Topic terminated exception thrown by Pulsar client.
static class
Consumer assign exception thrown by Pulsar client.
static class
Unsupported authentication exception thrown by Pulsar client.
void
Acknowledge the consumption of a list of message.
void
Acknowledge the consumption of a single message.
void
Acknowledge the consumption of a single message, identified by its
MessageId
.
void
Acknowledge the consumption of
Messages
.
void
Acknowledge the reception of all the messages in the stream up to (and including) the provided message.
void
Acknowledge the reception of all the messages in the stream up to (and including) the provided message.
Batch receiving messages.
void
Close the consumer and stop the broker to push more messages.
void
Close the producer and releases resources allocated.
void
Close the PulsarClient and release all the resources.
Finalize the creation of the
Producer
instance.
Finalize the creation of the
Reader
instance.
Finalize the creation of the
TableView
instance.
void
void
Flush all the messages buffered in the client and wait until all messages have been successfully persisted.
Get/Create an authentication data provider which provides the data that this client will be sent to the broker.
Get the last message id available for consume.
boolean
Check if there is any message available to read from the current position.
Create a transaction builder that can be used to configure
and construct a transaction.
Read the next message in the topic.
Read the next message in the topic waiting for a maximum time.
Receives a single message.
Receive a single message.
void
reconsumeLater the consumption of
Messages
.
void
reconsumeLater the consumption of
Messages
.
void
reconsumeLater the consumption of
Messages
.
void
reconsumeLater the reception of all the messages in the stream up to (and including) the provided message.
void
Consumer.seek(long timestamp)
Reset the subscription associated with this consumer to a specific message publish time.
void
Reset the subscription associated with this consumer to a specific message ID or message publish time.
void
Reset the subscription associated with this consumer to a specific message id.
void
Reader.seek(long timestamp)
Reset the subscription associated with this reader to a specific message publish time.
void
Reset the subscription associated with this consumer to a specific message ID or message publish time.
void
Reset the subscription associated with this reader to a specific message id.
TypedMessageBuilder.send()
Send a message synchronously.
void
Perform immediate shutdown of PulsarClient.
void
Initialize the authentication provider.
Finalize the
Consumer
creation by subscribing to the topic.
void
Unsubscribe the consumer.
void
Update the service URL this client is using.