Skip to content
This repository has been archived by the owner on Mar 24, 2021. It is now read-only.

Support RecordBatch #831

Open
emmettbutler opened this issue Jul 11, 2018 · 1 comment
Open

Support RecordBatch #831

emmettbutler opened this issue Jul 11, 2018 · 1 comment
Labels
enhancement

Comments

@emmettbutler
Copy link
Contributor

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.
@emmettbutler emmettbutler mentioned this issue Jul 24, 2018
Open
@emmettbutler
Copy link
Contributor Author

There is also a change to MessageSet in 0.10 (the addition of timestamp) that should be supported.

@emmettbutler emmettbutler mentioned this issue Jul 26, 2018
Open
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
enhancement
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@emmettbutler