HasNext checks if there is any message available to read from the current position If there is any errors, it will return false

NewMetricsProvider returns metrics registered to registerer.

Put enqueue one item, block if the queue is full This is currently used for the internal testing

Serialize the message id into a sequence of bytes that can be stored somewhere else

Unsubscribe the consumer Unsubscribing will cause the subscription to be deleted, and all the retained data can potentially be deleted based on messa

EventTime returns the event time associated with this message. It is typically set by the applications via `ProducerMessage.EventTime`. If EventTime i

PutUnsafe enqueue one item without locking the queue, block if the queue is full

Size return the current size of the queue

AckID the consumption of a single message, identified by its MessageID When `EnableBatchIndexAcknowledgment` is false, if a message ID represents a me

NewBlockingQueue init block queue and returns a BlockingQueue

GetData returns the authentication data identifying this client that will be sent to the broker.

Init the authentication provider.

NewAvroSchema creates a new AvroSchema Note: the function will panic if creation of codec fails

Clear will clear the current buffer data.

Get returns the config of the tenant.

Size returns the number of key-value mappings in the TableView.

TopicPartitions Fetches the list of partitions for a given topic If the topic is partitioned, this will return a list of partition names. If the topi

NewDefaultMessageCrypto get the instance of message crypto

NewLookupService init a lookup service struct and return an object of LookupService.

OrderingKey returns the ordering key of the message, if any

PartitionIdx returns the message partitionIdx

Release decreases the reference count and returns the buffer to the pool if it's associated with a buffer pool and the count reaches zero.

AckIDList the consumption of a list of messages, identified by their MessageIDs This method should be used when `AckWithResponse` is true. Otherwise,

BatchSize returns 0 or the batch size, which must be greater than BatchIdx()

Close closes the connection by closing underlying socket connection and closeCh. This also triggers callbacks to the ConnectionClosed listeners.

Commit You can commit the transaction after all the sending/acknowledging operations with the transaction success.

GetMessageTTL returns the message TTL for a topic. Returns -1 if not set

Lookup perform a lookup for the given topic, confirm the location of the broker where the topic is located, and return the LookupResult.

NewBuffer creates and initializes a new Buffer using buf as its initial contents.

NewTransaction creates a new Transaction instance. This function is used to initiate a new transaction for performing atomic operations on the messag

ProducerName returns the name of the producer that has published the message.

Retry the given operation until the returned error is nil or the context is done.

TimestampMillis return a time unix nano.

LatestMessageID returns a messageID that points to the latest message

Name func returns the identifier for this authentication method.

UnsubscribeForce the consumer, forcefully unsubscribe by disconnecting connected consumers. Unsubscribing will cause the subscription to be deleted,

_setConn sets the internal connection field of this partition consumer atomically. Note: should only be called by this partition consumer when a new c

checkSuccessful checks for a valid response and parses an error

createClientWithTC creates a new client with a transaction coordinator client to send request

initAvroCodec returns a Codec used to translate between a byte slice of either binary or textual Avro data and native Go data.