Uses of Class
org.apache.pulsar.client.api.PulsarClientException
Packages that use PulsarClientException
-
Uses of PulsarClientException in org.apache.pulsar.client.api
Subclasses of PulsarClientException in org.apache.pulsar.client.apiModifier and TypeClassDescriptionstatic 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
TopicMigration exception thrown by Pulsar client.static class
Topic terminated exception thrown by Pulsar client.static class
Consumer assign exception thrown by Pulsar client.static class
static class
Unsupported authentication exception thrown by Pulsar client.Methods in org.apache.pulsar.client.api that return PulsarClientExceptionMethods in org.apache.pulsar.client.api that throw PulsarClientExceptionModifier and TypeMethodDescriptionvoid
MessageAcknowledger.acknowledge
(List<MessageId> messageIdList) Acknowledge the consumption of a list of message.default void
MessageAcknowledger.acknowledge
(Message<?> message) void
MessageAcknowledger.acknowledge
(MessageId messageId) Acknowledge the consumption of a single message.default void
MessageAcknowledger.acknowledge
(Messages<?> messages) default void
MessageAcknowledger.acknowledgeCumulative
(Message<?> message) void
MessageAcknowledger.acknowledgeCumulative
(MessageId messageId) Acknowledge the reception of all the messages in the stream up to (and including) the provided message.Consumer.batchReceive()
Batch receiving messages.ClientBuilder.build()
Construct the finalPulsarClient
instance.void
Consumer.close()
Close the consumer and stop the broker to push more messages.void
Producer.close()
Close the producer and releases resources allocated.void
PulsarClient.close()
Close the PulsarClient and release all the resources.ProducerBuilder.create()
Finalize the creation of theProducer
instance.ReaderBuilder.create()
Finalize the creation of theReader
instance.TableViewBuilder.create()
Finalize the creation of theTableView
instance.void
MessageCrypto.encrypt
(Set<String> encKeys, CryptoKeyReader keyReader, Supplier<BuilderT> messageMetadataBuilderSupplier, ByteBuffer payload, ByteBuffer outBuffer) void
Producer.flush()
Flush all the messages buffered in the client and wait until all messages have been successfully persisted.default AuthenticationDataProvider
Authentication.getAuthData()
default AuthenticationDataProvider
Authentication.getAuthData
(String brokerHostName) Get/Create an authentication data provider which provides the data that this client will be sent to the broker.Consumer.getLastMessageId()
Deprecated.Consumer.getLastMessageIds()
Get all the last message id of the topics the consumer subscribed.Reader.getLastMessageIds()
Get all the last message id of the topics the reader subscribed.boolean
Reader.hasMessageAvailable()
Check if there is any message available to read from the current position.Reader.readNext()
Read the next message in the topic.Read the next message in the topic waiting for a maximum time.Consumer.receive()
Receives a single message.Receive a single message.void
Consumer.reconsumeLater
(Message<?> message, long delayTime, TimeUnit unit) reconsumeLater the consumption ofMessages
.void
Consumer.reconsumeLater
(Message<?> message, Map<String, String> customProperties, long delayTime, TimeUnit unit) reconsumeLater the consumption ofMessages
.void
Consumer.reconsumeLater
(Messages<?> messages, long delayTime, TimeUnit unit) reconsumeLater the consumption ofMessages
.void
Consumer.reconsumeLaterCumulative
(Message<?> message, long delayTime, TimeUnit unit) 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.Sends a message.TypedMessageBuilder.send()
Send a message synchronously.void
PulsarClient.shutdown()
Perform immediate shutdown of PulsarClient.void
Authentication.start()
Initialize the authentication provider.ConsumerBuilder.subscribe()
Finalize theConsumer
creation by subscribing to the topic.void
Consumer.unsubscribe()
Unsubscribe the consumer.void
Consumer.unsubscribe
(boolean force) Unsubscribe the consumer.void
PulsarClient.updateServiceUrl
(String serviceUrl) Update the service URL this client is using.
Consumer.getLastMessageIds()
instead.