AddPartition appends a partition to the request. On v8+ it targets Groups[0] (seeded from ConsumerGroup if needed); use AddGroupPartition for v8 batch

AddPartitionsToTxn send a request to add partition to txn and returns a response or error

Alters client quota configurations with the specified alterations. This operation is supported by brokers with version 2.6.0.0 or higher.

AlterConsumerGroupOffsets alters offsets for the specified group by committing the provided offsets and metadata. The request targets the group's coor

AsyncClose initiates a shutdown of the PartitionOffsetManager. This method will return immediately, after which you should wait until the 'errors' cha

Begin prepares the client for the SCRAM exchange with the server with a user name and a password

Broker returns the active Broker if available for the broker ID.

CommitOffset return an Offset commit response or error

CreateAcls sends a create acl request and returns a response or error

CreateTopics send a create topic request and returns create topic response

Deletes a consumer group offset

DeleteGroups sends a request to delete groups and returns a response or error

DeleteOffsets sends a request to delete group offsets and returns a response or error

DeleteTopics sends a delete topic request and returns delete topic response

Get client quota configurations corresponding to the specified filter. This operation is supported by brokers with version 2.6.0.0 or higher.

Get information about the nodes in the cluster

DescribeGroups return describe group response or error

Get information about SCRAM users

EndTxn sends a request to end txn and returns a response or error

ExpectInputAndFail sets an expectation on the mock producer that a message will be provided on the input channel. The mock producer will handle the me

ExpectInputWithMessageCheckerFunctionAndFail sets an expectation on the mock producer that a message will be provided on the input channel. The mock p

ExpectSendMessageWithMessageCheckerFunctionAndFail sets an expectation on the mock producer that SendMessage will be called. The mock producer will fi

Setting expectations ExpectSendMessageWithMessageCheckerFunctionAndSucceed sets an expectation on the mock producer that SendMessage will be called.

FindCoordinator sends a find coordinate request and returns a response or error

GetGroup returns the per-group entry for groupID, or nil if absent or on v0-7.

GroupError returns the group-level error: for v8+ the error of Groups[0], otherwise the top-level Err.

Heartbeat returns a heartbeat response or error

InSyncReplicas returns the set of all in-sync replica IDs for the given partition. In-sync replicas are replicas which are fully caught up with the pa

InitProducerID sends an init producer request and returns a response or error

InitProducerID retrieves information required for Idempotent Producer

IsPaused indicates if this partition consumer is paused or not

JoinGroup returns a join group response or error

LastRequest returns a copy of the most recent request handled, for assertions.

LeastLoadedBroker retrieves broker that has the least responses pending

ListConsumerGroupOffsetsBatch fetches committed offsets for multiple consumer groups in a single round trip per coordinator using OffsetFetch v8+ (KIP

ListGroups return a list group response or error

ListOffsets lists offsets for the specified topic partitions. Each value is OffsetNewest, OffsetOldest, or a timestamp in milliseconds. Results are ke

Login will use the given KerberosClient to login and get a ticket for the given spn.

NewConsumerGroupMetadataFromSession builds metadata from a live consumer group session, copying the member ID and generation ID so the broker can fenc

NewCustomHashPartitioner is a wrapper around NewHashPartitioner, allowing the use of custom hasher. The argument is a function providing the instance,

NewCustomPartitioner creates a default Partitioner but lets you specify the behavior of each component via options

NewMockBrokerListener behaves like newMockBrokerAddr but accepts connections on the listener specified.

NewMurmur2Partitioner returns a Partitioner that replicates the partitioning behavior of the Apache Kafka Java client's DefaultPartitioner. It uses th

NewRoundRobinPartitioner returns a Partitioner which walks through the available partitions one at a time.

NewTopicConfig makes a configuration which defaults to 32 partitions for every topic.

PauseAll suspends fetching from all partitions. Future calls to the broker will not return any records from these partitions until they have been resu

Produce returns a produce response or error

ResumeAll resumes all partitions which have been paused with Pause()/PauseAll(). New calls to the broker will return records from these partitions if

SyncGroup returns a sync group response or error

Topics returns a list of topics, as registered with SetTopicMetadata

addError adds an error for a topic to the set. The wrap preserves the underlying error for errors.Is/As.

allocateResponseBody returns a fresh response struct for the given api key and version, or nil when the key is unknown. Not used at runtime, but mirro

The assignment should improve the overall balance of the partition assignments to consumers.