This repository was archived by the owner on Mar 24, 2021. It is now read-only.

Description
Since Kafka 0.11, the MessageSet format has had an updated version called RecordBatch. We should investigate what it would take to support this format, and what the benefits would be. This will probably require significant changes within protocol.py to intelligently switch between MessageSet implementations based on Kafka broker version.