Close the reader and stop the broker to push more messages

String returns message id in string format

NewClient Creates a pulsar client instance

CreateProducer Creates the producer instance This method will block until the producer is created successfully

Close Closes the Client and free associated resources

Subscribe Creates a `Consumer` by subscribing to a topic. If the subscription does not exist, a new subscription will be created and all messages pub

Receive a single message. This calls blocks until a message is available.

Send a message This call will be blocking until is successfully acknowledged by the Pulsar broker. Example: producer.Send(ctx, pulsar.ProducerMessage{

Unlock unlocks the queue Must be called after Lock() to release the lock

Lock locks the queue for manual control Users must call Unlock() after finishing their operations

Payload returns the payload of the message

Add will add single message to batch.

ID returns the unique message ID associated with this message. The message id can be used to univocally refer to a message without having the keep the

Ack the consumption of a single message

GetWithContext returns the config of the tenant.

The topic name can be in two different forms, one is fully qualified topic name, the other one is short topic name

New returns a new client

SendAsync a message in asynchronous mode. The send operation completes in the background and the provided callback is invoked once the broker acknowle

DeleteWithContext deletes a topic, this function can delete both partitioned or non-partitioned topic @param ctx context used for the request @param

Next reads the next message in the topic, blocking until a message is available

Key returns the key of the message, if any

Create creates a partitioned or non-partitioned topic @param topic topicName struct @param partitions number of topic partitions, when setting to 0,

ParseTopicName parse the given topic name and return TopicName.

CreateReader Creates a Reader instance. This method will block until the reader is created successfully.

Properties are application defined key/value pairs that will be attached to the message. Returns the properties attached to the message.

DefaultNopLogger returns a nop logger.

EntryID returns the message entryID

LedgerID returns the message ledgerID

BatchIdx returns the message batchIdx

Name returns the name of consumer.

Topic from which this reader is reading from

EarliestMessageID returns a messageID that points to the earliest message available in a topic

Flush all the messages buffered in the client and wait until all messageshave been successfully persisted.

GetSchemaValue returns the de-serialized value of the message, according to the configuration.

Create a new unique request id

checkMessageIDType checks if the MessageID is user-defined

_getConn returns internal connection field of this partition producer atomically. Note: should only be called by this partition producer before attemp

Get returns the value to which the specified key is mapped, or nil if this map contains no mapping for the key.

nolint:all

GetSchemaInfo retrieves the latest schema of a topic

Chan returns a channel to consume messages from

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

Result get error's original result.

Nack acknowledges the failure to process a single message. When a message is "negatively acked" it will be marked for redelivery after some fixed del

_getConn returns internal connection field of this partition consumer atomically. Note: should only be called by this partition consumer before attemp