0.8.1.1 release is out would be cool to use broker to store offsets off to zookeeper https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommit/FetchAPI