AutoAck returns an ack value that should be passed to proxy.Consume function when a caller wants the consumed message to be acknowledged immediately.

NewAck creates an acknowledgement instance from a partition and an offset.

NewSet creates a proxy.Set from a cluster-to-proxy map and a default proxy.

NoAck returns an ack value that should be passed to proxy.Consume function when a caller does not want to acknowledge anything.

Spawn creates a proxy instance and starts its internal goroutines.

Set represents a collection of proxy.T instances with a default value.

T implements a proxy to a particular Kafka/ZooKeeper cluster.