Adds support for handling Fetch API responses when the broker responds with a magic byte value of 2 (also known as RecordBatch) as described in the docs. This change was introduced in Kafka 0.11.
There are outstanding issues that need to be addressed before this can be merged in:
TODOs
[ ] Handle batch-level CRCs (currently the consumer must disable CRC checks)
[ ] Determine if we can leave the questionable "divide everything by two" logic in ReadVarint
[ ] Decide if we're okay with the giant array literal in the unit test (intentionally left that commit at the tip of the branch to allow it to be easily discarded)
Adds support for handling Fetch API responses when the broker responds with a magic byte value of 2 (also known as RecordBatch) as described in the docs. This change was introduced in Kafka 0.11.
There are outstanding issues that need to be addressed before this can be merged in:
TODOs
ReadVarint