NewClient creates a new client instance.

NewConfig returns a new configuration instance with sane defaults.

NewConsumer initializes a new consumer.

NewConsumerFromClient initializes a new consumer from an existing client.

NewOffsetStash inits a blank stash.

StrategyRange is the default and assigns partition ranges to consumers.

StrategyRoundRobin assigns partitions by alternating over consumers.

Client is a group client.

Config extends sarama.Config with Group specific namespace.

Consumer is a cluster group consumer.

Error instances are wrappers for internal errors with a context and may be returned through the consumer's Errors() channel.

Notification are state events emitted by the consumers on rebalance.

OffsetStash allows to accumulate offsets and mark them as processed in a bulk.

PartitionConsumer allows code to consume individual partitions from the cluster.

NotificationType defines the type of notification.

Strategy for partition to consumer assignement.