Re: Reading from __consumer_offsets in 0.9

2015-12-14 Thread Jason Gustafson
Hey Brian, I think we've made these methods public again in trunk, but that won't help you with 0.9. Another option would be to write a parser yourself since the format is fairly straightforward. This would let you remove a dependence on Kafka internals which probably doesn't have strong compatibi

Reading from __consumer_offsets in 0.9

2015-12-14 Thread Brian J. Vanecek
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