Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
core: add support for flexible versions
Varint code lifted from the java kafka repo, with the caveat that we need to specify a byte size by bitmasking due to how python integers handle the sign bit Serialization tests lifted from java repo as well - Add support for varints - Add support for compact collections (byte array, string, array) - Add support for new request and response headers, supporting flexible versions - Add List / Alter partition reassignments apis
- Loading branch information
Tincu Gabriel
committed
Nov 19, 2020
1 parent
53dc740
commit eaedde8
Showing
6 changed files
with
347 additions
and
17 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.