Issue in offset fetch

[mahendra]

In consumer.py, if you un-comment the lines (for 0.8.1) to enable OffsetFetchRequest on consumer init, the following error occurs at the broker

kafka.common.KafkaException: Wrong request type 7
    at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:51)
    at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:49)
    at kafka.network.Processor.read(SocketServer.scala:345)
    at kafka.network.Processor.run(SocketServer.scala:245)
    at java.lang.Thread.run(Unknown Source)

and kafka-python raises an exception

Noticed this in kafka trunk as well as 0.8

[mahendra]

Sorry, this is my mistake. It is working fine once I compile kafka from trunk and run it (had messed up my configuration while switching between 0.8 and trunk earlier)

[mumrah]

Yea, this happens to me all the time. I really just wish they had pulled these new offset APIs into 0.8 - would have made life easier