Token returns an access token. The implementation should ensure token reuse so that multiple calls at connect time do not create multiple tokens. The

Topic returns the consumed topic name.

Topics returns the set of available topics as retrieved from the cluster metadata. This method is the same as Client.Topics(), and is provided for con

TxnOffsetCommit sends a request to commit transaction offsets and returns a response or error

UnmarshalText returns a CompressionCodec from its string representation.

UnmarshalText takes a text representation of the operation and converts it to an AclOperation

UnmarshalText takes a text representation of the permission type and converts it to an AclPermissionType

UnmarshalText takes a text representation of the resource type and converts it to an AclResourceType

UnmarshalText takes a text representation of the resource pattern type and converts it to an AclResourcePatternType

WithCustomFallbackPartitioner lets you specify what HashPartitioner should be used in case a Distribution Key is empty

WithCustomHashFunction lets you specify what hash function to use for the partitioning

WithHashUnsigned means the partitioner treats the hashed value as unsigned when partitioning. This is intended to be combined with the crc32 hash alg

add specified offsets to current transaction.

addTopics adds topics to the refresh. You need to hold the lock to call this method.

addTopicsFrom adds topics from the next refresh to the current refresh. You need to hold the lock to call this method.

adjustCooperativeAssignment withholds partitions until their old owner revokes them

Called during pop() to adjust the length of the field. It should return the difference in bytes between the last computed length and current length.

Append the GSS-API header to the payload, conforming to RFC-2743 Section 3.1, Mechanism-Independent Token Format https://tools.ietf.org/html/rfc2743#

assertGroupOffset asserts result has groupID with the expected offset at topic/partition.

claims resolve their start offsets when created, so wait for all of them before producing to a randomly selected partition

Balance assignments across consumers for maximum fairness and stickiness.

boundedDecompress reads from a streaming decompressor into a pooled buffer, capping the read at limit+1 bytes so an oversized batch is caught before i

boundedSnappyDecode decodes xerial/snappy into a capped buffer grown on demand up to limit. DecodeCapped returns ErrDstTooSmall rather than writing pa

boundedZstdDecode decodes into a pooled buffer using a decoder whose max memory is capped at limit, so an oversized frame fails without allocating its

buildTargetAssignment grows each partition's replica list to targetRF by appending the least-used broker IDs not already in the partition's list. Exis

Indicates that all required data is now available to calculate and check the field. SaveOffset is guaranteed to have been called first. The implementa

clear clears the refresh state. You need to hold the lock to call this method.

consumeKeyedFromPartition consumes up to count messages from a specific partition, returning them as key+value pairs.

Construct Kerberos AP_REQ package, conforming to RFC-4120 https://tools.ietf.org/html/rfc4120#page-84

https://cwiki.apache.org/confluence/display/KAFKA/KIP-226+-+Dynamic+Broker+Configuration

deregisterController removes the cached controllerID