NewProtoSchemaWithValidation creates a new ProtoSchema and error to indicate codec failure

OnNegativeAcksSend This method will be called when a redelivery from a negative acknowledge occurs.

OnSendAcknowledgement This method is called when the message sent to the broker has been acknowledged, or when sending the message fails.

PeekMessages peeks messages from a topic subscription

RemoveMaxConsumersPerSubscription removes max consumers per subscription for a topic

RemoveMaxTopicsPerNamespace removes maxTopicsPerNamespace configuration for a namespace, defaulting to broker settings

RemovePersistence removes the persistence policies for a topic

RemoveSubscriptionExpirationTime removes subscription expiration time from a namespace, defaulting to broker settings

RemoveTopicAutoCreation removes topic auto-creation config for a namespace, defaulting to broker settings

SchemaVersion get the schema version of the message, if any

SetCompactionThreshold sets the compaction threshold for a topic @param topic topicName struct @param threshold maximum number of backlog bytes befor

SetEncryptionParam set encryption parameter in to the MessageMetadata

SetMaxConsumers sets max number of consumers for a topic @param topic topicName struct @param maxConsumers max number of consumer

SetMaxConsumersPerSubscription sets max consumers per subscription for a topic

SetMaxTopicsPerNamespace sets maxTopicsPerNamespace for a namespace. nolint: revive // It's ok here to use a built-in function name (max)

SetMaxUnackMessagesPerConsumer sets max unacked messages policy on consumer for a topic @param topic topicName struct @param maxUnackedNum max unAcke

SetMaxUnackMessagesPerSubscription sets max unacked messages policy on subscription for a topic @param topic topicName struct @param maxUnackedNum ma

SetOffloadDeleteLag sets the offload deletion lag for a namespace

SetOffloadThresholdInSeconds sets the offloadThresholdInSeconds for a namespace

SetPersistence sets the persistence policies for a topic

SetRedirectedClusterURI set the redirected cluster URI for lookups

SetRetention sets the retention policy for a topic

SetSubscriptionExpirationTime sets the subscription expiration time on a namespace

SetTopicAutoCreation sets topic auto-creation config for a namespace, overriding broker settings

Subscription get a subscription for the consumer

Update updates number of partitions of a non-global partitioned topic It requires partitioned-topic to be already exist and number of new partitions m

UpdateDynamicConfiguration updates dynamic configuration value in to Zk that triggers watch on brokers and all brokers can update {@link ServiceConfig

ackID acknowledges the consumption of a message and optionally waits for response from the broker.

ackIDCommon handles common logic for acknowledging messages with or without transactions. withTxn should be set to true when dealing with transactions

checkSuccessful checks for a valid response and parses an error

decodeJSONBody is used to JSON decode a body

encodeJSONBody is used to JSON encode a body