ApiVersions return api version response or error

AssignmentData returns the serialized assignment data for the specified memberID

AsyncClose triggers a shutdown of the producer. The shutdown has completed when both the Errors and Successes channels have been closed. When calling

the metadata overhead of CRC, flags, etc.

Close corresponds with the Close method of sarama's SyncProducer implementation. By closing a mock syncproducer, you also tell it that no more SendMes

Close corresponds with the Close method of sarama's Producer implementation. By closing a mock producer, you also tell it that no more input will be p

Controller returns the cluster controller broker. It will return a locally cached value if it's available.

Creates an access control list (ACL) which is bound to a specific resource. This operation is not transactional so it may succeed or fail. If you atte

Get the configuration for the specified resources. The returned configuration includes default values and the Default is true can be used to distingui

Describe the given consumer groups.

Get information about all log directories on the given set of brokers

FetchOffset returns an offset fetch response or error

GetBlock returns the block for topic/partition. On v8+ it looks up Groups[0].

IncrementalAlterConfig Incrementally Update the configuration for the specified resources with the default options. This operation is supported by bro

IsTransactional return true when current producer is transactional.

List the consumer groups available in the cluster.

MarshalText returns the text form of the AclOperation (name without prefix)

NewConsumerGroupMetadata returns metadata carrying only the group ID, with GenerationID set to GroupGenerationUndefined so the broker performs no memb

NewHashPartitioner returns a Partitioner which behaves as follows. If the message's key is nil then a random partition is chosen. Otherwise the FNV-1a

NewSyncProducerFromClient creates a new SyncProducer using the given client. It is still necessary to call Close() on the underlying client when shutt

YieldError will yield an error on the Errors channel of this partition consumer when it is consumed. By default, the mock consumer will not verify whe

messageValueChecker wraps a ValueChecker into a MessageChecker. Failure to encode the message value will return an error and not call the wrapped Valu

To record metrics when provided

mockMetadataFor builds a MockMetadataResponse with controller and brokers populated. Callers chain .SetLeader as needed.

newMockBroker spins up a MockBroker with auto-cleanup.

send txnmgnr save offsets to transaction coordinator.

refreshOrQueue returns a channel the refresh needs to wait on, and a boolean that indicates whether waiting on the channel will return the result of t

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

shouldCloseBrokerConn reports whether a transport error should trigger closing.

singleBrokerAdmin wires a single mock broker that names itself controller, installs the given per-request handlers, and returns a ready admin client.

staleControllerAdmin wires two mock brokers into a controller-failover scenario and returns a ready admin client. Broker 1 answers reqType with errRes

tryBuildFlushingBatch tries to promote the accumulating batch (or whichever of its partitions aren't muted) into the flushing batch. If nothing could

waitForSpace makes space in the accumulating batch by flushing. It loops until the message fits.

Add assigns a topic with a number partitions to a member.

AddMessageToTxn add message offsets to current transaction.

AddMessageToTxnWithGroupMetadata adds the message offset to the current transaction, carrying the consumer group member metadata so the broker can fen

AddOffsetsToTxn add associated offsets to current transaction.

Update the configuration for the specified resources with the default options. This operation is supported by brokers with version 0.11.0.0 or higher.

AsyncProduce sends a produce request and eventually call the provided callback with a produce response or an error. Waiting for the response is gener

Closed returns true if the client has already had Close called on it

Controller returns the cluster controller broker. It will return a locally cached value if it's available. You can call RefreshController to update th

Delete a consumer group.

Get the configuration for the specified resources. The returned configuration includes default values and the Default is true can be used to distingui

ElectLeaders allows to trigger the election of preferred leaders for a set of partitions.

Setting expectations ExpectInputWithMessageCheckerFunctionAndSucceed sets an expectation on the mock producer that a message will be provided on the

ExpectMessagesDrainedOnClose sets an expectation on the partition consumer that the messages channel will be fully drained when Close is called. If th

ExpectSendMessageAndFail sets an expectation on the mock producer that SendMessage will be called. The mock producer will handle the message as if it

Fetch returns a FetchResponse or error

GenerationID returns the current generation ID.

GetAvailableOffsets return an offset response or error

Input corresponds with the Input method of sarama's Producer implementation. You have to set expectations on the mock producer before writing messages