NewTestConfig returns a config meant to be used by tests. Due to inconsistencies with the request versions the clients send using the default Kafka ve

NewMockBroker launches a fake Kafka broker. It takes a TestReporter as provided by the test framework and a channel of responses to use. If an error

Close terminates the broker blocking until it stops internal goroutines and releases all resources.

Addr returns the broker connection string in the form "<address>:<port>".

BrokerID returns broker ID assigned to the broker.

SetHandlerByMap defines mapping of Request types to MockResponses. When a request is received by the broker, it looks up the request type in the map a

Close shuts down all broker connections managed by this client. It is required to call this function before a client object passes out of scope, as it

NewClusterAdmin creates a new ClusterAdmin using the given broker addresses and configuration.

NewClient creates a new Client. It connects to one of the given broker addresses and uses that broker to automatically fetch metadata on the rest of t

testing API

Close shuts down the admin and closes underlying client.

NewFunctionalTestConfig returns a config meant to be used by functional tests.

Add appends elem, growing the buffer if it is full.

IsAtLeast return true if and only if the version it is called on is greater than or equal to the version passed in: V1.IsAtLeast(V2) // false V2.Is

Input is the input channel for the user to write messages to that they wish to send.

Messages returns the read channel for the messages that are returned by the broker.

Done should return true when the SCRAM conversation is over.

NewAsyncProducer creates a new AsyncProducer using the given broker addresses and configuration.

testing API

ConsumePartition creates a PartitionConsumer on the given topic/partition with the given offset. It will return an error if this Consumer is already c

ID returns the broker ID retrieved from Kafka's metadata, or -1 if that is not known.

NewConsumer creates a new consumer using the given broker addresses and configuration.

Open tries to connect to the Broker if it is not already connected or connecting, but does not block waiting for the connection to complete. This mean

Errors returns a read channel of errors that occurred during consuming, if enabled. By default, errors are logged and not returned over this channel.

Name uniquely identifies the strategy.

Encode takes an Encoder and turns it into bytes while potentially recording metrics.

SendMessage produces a given message, and returns only when it either has succeeded or failed to produce. It will return the partition and the offset

Addr returns the broker address as either retrieved from Kafka's metadata or passed to NewBroker.

RefreshMetadata takes a list of topics and queries the cluster to refresh the available metadata for those topics. If no topics are provided, it will

retryOnError will repeatedly call the given (error-returning) func in the case that its response is non-nil and retryable (as determined by the provid

Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited but before the offsets are committed for the very last time.

NewBroker creates and returns a Broker targeting the given host:port address. This does not attempt to actually connect, you have to call Open() for t

Plan implements BalanceStrategy.

Primitives

Brokers returns the current set of active brokers as retrieved from cluster metadata.

Config returns the Config struct of the client. This struct should not be altered after it has been created.

NewConfig returns a new configuration instance with sane defaults.

Primitives

NewSyncProducer creates a new SyncProducer using the given broker addresses and configuration.

NewTestConfig returns a config meant to be used by tests. Due to inconsistencies with the request versions the clients send using the default Kafka ve

ParseKafkaVersion parses and returns kafka version or error from a string