API Versioning #4
Description
Came across this through reddit this morning. Incidentally, I had started my own implementation of the Kafka protocol a couple of days ago, but got stuck at the following problem:
Current versions of Kafka support three different versions of Offset Commit Request and two variants of Offset Fetch Request, each with very different semantics. As there is no obvious way to somehow negotiate which one to use with the server, it should be up to the client to choose one -- preferably such that the "current" one is picked by default.
As far as I can see, this library doesn't handle this (yet?). What are your plans to address this problem?
As an aside, the definition of OffsetCommitRequest seems to be incorrect -- it looks like a mixture between v1 and v2