Makes a request to kafka to add a list of partitions to the current transaction.

private broker management helpers

Reassign a specific partition to a new consumer

registerBroker makes sure a broker received by a Metadata or Coordinator request is registered in the brokers map. It returns the broker that is regis

Releases/removes closed POMs once they are clean (or when forced)

releaseSelectedPOMs holds the write lock while closing POM error channels

resize rebuilds buf with head back at index 0, sized to 2*count but never below minLen so the zero value of Queue grows on first Add.

b.lock must be held by caller a non-nil res results in a response promise being created

b.lock must be held by caller

b.lock must be held by caller

setupToxiProxies will configure the toxiproxy proxies with routes for the kafka brokers if they don't already exist

subscriptionMetadata builds the ConsumerGroupMemberMetadata for a single strategy in a JoinGroup request. If the strategy implements SubscriptionUserD

wait returns the channel on which you can wait for the refresh to complete. You need to hold the lock to call this method.

waitUntilMuted blocks until all partitions in the set can be muted, then mutes them. Returns false if the muter was closed before all partitions could

AddGroupBlock adds a block for groupID/topic/partition, creating the group entry if needed. On v0-7 it falls back to AddBlock and ignores groupID.

AddGroupPartition adds a partition under group in a v8+ batch, creating the group entry if absent.

AddOffsetsToTxnWithGroupMetadata adds associated offsets to the current transaction, carrying the consumer group member metadata so the broker can fen

AddRecordBatchWithTimestamp is similar to AddRecordWithTimestamp But instead of appending 1 record to a batch, it append a new batch containing 1 reco

AlterConfigs sends a request to alter config and return a response or error

AssignmentData serializes the set of topics currently assigned to the specified member as part of the supplied balance plan

PartitionConsumer interface implementation AsyncClose implements the AsyncClose method from the sarama.PartitionConsumer interface.

Implement Producer interface AsyncClose corresponds with the AsyncClose method of sarama's Producer implementation. By closing a mock producer, you

Authorize performs the kerberos auth handshake for authorization

AuthorizeV2 performs the SASL v2 GSSAPI authentication with the Kafka broker.

Claims returns information about the claimed partitions by topic.

Close stops the OffsetManager from managing offsets. It is required to call this function before an OffsetManager object passes out of scope, as it wi

Commit the offset to the backend Note: calling Commit performs a blocking synchronous operation.

ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages(). Once the Messages() channel is closed, the Handler must finish its process

Creates access control lists (ACLs) which are bound to specific resources. This operation is not transactional so it may succeed for some ACLs while f