TransactionCoordinator returns the coordinating broker for a transaction id. It will return a locally cached value if it's available. You can call Ref

Get current transaction status.

AbortTxn abort current transaction.

Coordinator returns the coordinating broker for a consumer group. It will return a locally cached value if it's available.

Creates a new topic. This operation is supported by brokers with version 0.10.1.0 or higher. It may take several seconds after CreateTopic returns suc

GetOffset queries the cluster to get the most recent available offset at the given time (in milliseconds) on the topic/partition combination. Time sho

NewBalanceStrategySticky returns a sticky balance strategy, which assigns partitions to members with an attempt to preserve earlier assignments while

Pause suspends fetching from the requested partitions. Future calls to the broker will not return any records from these partitions until they have be

TxnStatus return current producer transaction status.

Build a new transaction manager sharing producer client.

AsyncClose initiates a shutdown of the PartitionConsumer. This method will return immediately, after which you should continue to service the 'Message

Delete records whose offset is smaller than the given offset of the corresponding partition. This operation is supported by brokers with version 0.11.

Delete a topic. It may take several seconds after the DeleteTopic to returns success and for all the brokers to become aware that the topics are gone.

Describe some topics in the cluster.

ExpectSendMessageWithCheckerFunctionAndSucceed sets an expectation on the mock producer that SendMessage will be called. The mock producer will first

NewBalanceStrategyRoundRobin returns a round-robin balance strategy, which assigns partitions to members in alternating order. For example, there are

NewConsumerFromClient creates a new consumer using the given client. It is still necessary to call Close() on the underlying client when shutting down

NewMockBrokerAddr behaves like newMockBroker but listens on the address you give it rather than just some ephemeral port.

Plan accepts a map of `memberID -> metadata` and a map of `topic -> partitions` and returns a distribution plan.

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

SendMessages produces a given set of messages, and returns only when all messages in the set have either succeeded or failed. Note that messages can s

Expectation API YieldMessage will yield a messages Messages channel of this partition consumer when it is consumed. By default, the mock consumer wi

bound receives so a stall fails one test instead of timing out the suite

isRetriableGroupCoordinatorError returns `true` if the given error type unwraps to an `ErrNotCoordinatorForConsumer`, `ErrConsumerCoordinatorNotAvaila

newMockTxnManager wires a transaction manager to broker using the standard metadata, find-coordinator and init-producer-id handshake. The caller owns

restrictApiVersion selects the appropriate API version for a given protocol body according to the client and broker version ranges. By default, it sel

setTypeFromFields sets type of Records depending on which of MsgSet or RecordBatch is not nil. The first return value indicates whether both fields ar

Alter the replica assignment for partitions. This operation is supported by brokers with version 2.4.0.0 or higher.

BeginTxn mark current transaction as ready.

CommitTxn commit current transaction.

Increase the number of partitions of the topics according to the corresponding values. If partitions are increased for a topic that has a key, the pa

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

List the consumer group offsets available in the cluster.

Provides info on ongoing partitions replica reassignments. This operation is supported by brokers with version 2.4.0.0 or higher.

MarkMessage marks a message as consumed.

NewConsumerGroupFromClient creates a new consumer group using the given client. It is still necessary to call Close() on the underlying client when sh

RefreshTransactionCoordinator retrieves the coordinator for a transaction id and stores it in local cache. This function only works on Kafka 0.11.0.0

ResetOffset resets to the provided offset, alongside a metadata string that represents the state of the partition consumer at that point in time. Rese

readFull ensures the conn ReadDeadline has been setup before making a call to io.ReadFull

triggerRedispatch queues a redispatch signal unless one is already pending. If the child is shutting down, the signal is ignored.

write ensures the conn Deadline has been setup before making a call to conn.Write

AddBlock adds a block for topic/partition. On v8+ it appends under Groups[0], creating it if needed.