GetReplicatedFrom returns the name of the cluster, from which the message is replicated.

GetTxnID Get the identified ID of the transaction.

IsMaxBackoffReached evaluates if the max number of retries is reached

MakeRequestWithContext can make a simple request and handle the response by yourself

NewAuthenticationBasic Creates Basic Authentication provider

NewAuthenticationTokenFromFile Creates new Authentication provider with specified auth token from a file

NewAuthenticationTokenFromFile return a interface of a Provider with a string token file path.

NewAvroSchemaWithValidation creates a new AvroSchema and error to indicate codec failure

NewHTTPLookupService init a http based lookup service struct and return an object of LookupService.

NewJSONSchemaWithValidation creates a new JSONSchema and error to indicate codec failure

NewLoggerWithLogrus creates a new logger which wraps the given logrus.Logger

NewNoopProvider returns a Provider interface that does not compress the data

Next returns the delay to wait before next retry

NumPartitions returns the number of partitions for a particular topic.

PrivateKey read private key from the given path

PublicKey read public key from the given path

PublishTime returns the publish time of this message. The publish time is the timestamp that a client publish the message.

ReadableSlice returns a new view of the readable items in the queue

ReconsumeLaterWithCustomProperties mark a message for redelivery after custom delay with custom properties

RemoveRetention removes the retention configuration on a topic

Send a request and block until the result is available

Retain increases the reference count

SetMaxProducers sets max number of producers for a topic @param topic topicName struct @param maxProducers max number of producer

SetReleaseCallback sets a callback function that will be called when the buffer is returned to a pool.

Unload a topic

UpdateProperties updates the properties of a topic

UpsertEncryptionKey add new or update existing EncryptionKeys in to the MessageMetadata

broadcast wakes all goroutines waiting on c. It is not required for the caller to hold c.L during the call.

mockOAuthServer will mock a oauth service for the tests

mockOAuthServerWithToken will mock a oauth service for the tests with a custom token.

mockOAuthServerWithToken will mock a oauth service for the tests with a custom token.

newBatchContainer init a batchContainer

newExchangeCodeRequest builds a new AuthTokenRequest wrapped in an http.Request

newGrabConnTestConsumerNoConn is like newGrabConnTestConsumer but does NOT pre-set _setConn, simulating the real first-call path where conn is nil. On

newRefreshTokenRequest builds a new RefreshTokenRequest wrapped in an http.Request