Deletes access control lists (ACLs) according to the supplied filters. This operation is not transactional so it may succeed for some ACLs while fail

DeleteAcls sends a delete acl request and returns a response or error

DescribeAcls sends a describe acl request and returns a response or error

DescribeConfigs sends a request to describe config and returns a response or error

Errors returns a read channel of errors that occurred during the consumer life-cycle. By default, errors are logged and not returned over this channel

ExpectErrorsDrainedOnClose sets an expectation on the partition consumer that the errors channel will be fully drained when Close is called. If this e

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

GetConsumerMetadata send a consumer metadata request and returns a consumer metadata response or error

GetGroupBlock returns the block for groupID/topic/partition, or nil on v0-7.

IncrementalAlterConfigs sends a request to incremental alter config and return a response or error

InitialOffset returns the initial offset that was used as a starting point for this claim.

IsPaused implements PartitionConsumer.

IsTransactional return true when current producer is transactional.

Lists access control lists (ACLs) according to the supplied filter. it may take some time for changes made by createAcls or deleteAcls to be reflected

MarkOffset marks the provided offset, alongside a metadata string that represents the state of the partition consumer at that point in time. The metad

Messages returns the read channel for the messages that are returned by the broker. The messages channel will be closed when a new rebalance cycle is

NewBalanceStrategyCooperativeSticky returns a cooperative sticky balance strategy Existing groups should first deploy it alongside their current eage

NewConsistentCRCHashPartitioner is like NewHashPartitioner except that it uses the *unsigned* crc32 hash of the encoded bytes of the message key modul

NewKerberosClient creates kerberos client used to obtain TGT and TGS tokens. It uses pure go Kerberos 5 solution (RFC-4121 and RFC-4120). uses gokrb5

NewLoadAwareSticky returns a load-aware wrapper around the sticky strategy. The observe callback is invoked once per JoinGroup; its return value is JS

NewManualPartitioner returns a Partitioner which uses the partition manually set in the provided ProducerMessage's Partition field as the partition to

NewOTelInterceptor processes span for intercepted messages and add some headers with the span data.

NewOffsetCommitRequest creates an OffsetCommitRequest initialized for admin use. The version-mapping logic mirrors offsetManager.constructRequest in

OfflineReplicas returns the set of all offline replica IDs for the given partition. Offline replicas are replicas which are offline

OnConsume is called when the consumed message is intercepted. Please avoid modifying the message until it's safe to do so, as this is _not_ a copy of

OnSend is called when the producer message is intercepted. Please avoid modifying the message until it's safe to do so, as this is _not_ a copy of the

PartitionNotReadable checks if partition is not readable

Partitions returns the sorted list of all partition IDs for the given topic. This method is the same as Client.Partitions(), and is provided for conve

Partitions returns the list of parititons for the given topic, as registered with SetTopicMetadata

Pause implements Consumer.

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

PauseAll implements Consumer.

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

Rack returns the broker's rack as retrieved from Kafka's metadata or the empty string if it is not known. The returned value corresponds to the broke

RefreshBrokers takes a list of addresses to be used as seed brokers. Existing broker connections are closed and the updated list of seed brokers will

RefreshController retrieves the cluster controller from fresh metadata and stores it in the local cache. Requires Kafka 0.10 or higher.

Remove members from the consumer group by given member identities. This operation is supported by brokers with version 2.3 or higher This is for stati

RequiresConsistency indicates to the user of the partitioner whether the mapping of key->partition is consistent or not. Specifically, if a partitione

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

Resume implements Consumer.

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

ResumeAll implements Consumer.

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

SetNotifier set a function that will get invoked whenever a request has been processed successfully and will provide the number of bytes read and writ

Expectation API SetTopicMetadata sets the clusters topic/partition metadata, which will be returned by Topics() and Partitions().

Setup is run at the beginning of a new session, before ConsumeClaim.