Skip to content

Updates to kafka.protocol.new to improve compatibility with old protocol#2735

Merged
dpkp merged 11 commits intomasterfrom
dpkp/new-protocol-compatibility-fixes
Mar 17, 2026
Merged

Updates to kafka.protocol.new to improve compatibility with old protocol#2735
dpkp merged 11 commits intomasterfrom
dpkp/new-protocol-compatibility-fixes

Conversation

@dpkp
Copy link
Copy Markdown
Owner

@dpkp dpkp commented Mar 17, 2026

  • ApiMessage[version]: validate version and support [-1] and len()
  • Allow StructField encoding with single str/int/float value when struct has only 1 field (in version)
  • Support ApiMessage __init__ w/ *args
  • Save DataContainer _version on decode; add __iter__ and __getitem__
  • Add MetadataRequest.ALL_TOPICS + NO_TOPICS
  • ApiMessage.parse_header() should be version-aware
  • Update compatibility tests

@dpkp dpkp force-pushed the dpkp/new-protocol-compatibility-fixes branch from 7099ee6 to 8eef933 Compare March 17, 2026 19:06
@dpkp dpkp merged commit 07b63bf into master Mar 17, 2026
19 checks passed
@dpkp dpkp deleted the dpkp/new-protocol-compatibility-fixes branch March 17, 2026 19:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant