AUTO: Brian J. Vanecek is out of the office (returning 08/15/2016)

I am out of the office until 08/15/2016. Note: This is an automated response to your message "Long commits lead to rebalance" sent on 8/11/2016 4:47:32 PM. This is the only notification you will receive while this person is away. ** This email and any attachments may contain information th

Reading from __consumer_offsets in 0.9

All, I'm running into a bit of a road-block consuming the offsets topic in 0.9. In 0.8, I was able to use kafka.server.OffsetManager.readMessageKey(..) and readMessageValue(..) to deserialize the offset messages. In 0.9, the equivalent methods in kafka.coordinator.GroupMetadataManager are priva