WARN: This is an obsolete design. The design that's implemented in Kafka 0.9.0 is described in this wiki.

Motivation

The motivation for moving to a new set of consumer client APIs with broker side co-ordination is laid out here.

...

This wiki has design details on the new consumer. This level of detail may be too verbose for people who are just trying to write a non-java consumer client using the new protocol. This wiki provides a step by step guide for writing a non-java 0.9 client.

...

Stopped consumption - In this state, the consumer stops consumption and commits offsets, until it joins the group again

Image RemovedImage Added

Co-ordinator

Following is a state diagram that describes the state changes on the co-ordinator for a particular group.

...