Skip to content
This repository has been archived by the owner on Nov 20, 2020. It is now read-only.

Protocol v11 #213

Merged
merged 3 commits into from
Mar 14, 2018
Merged

Protocol v11 #213

merged 3 commits into from
Mar 14, 2018

Conversation

eulerfx
Copy link
Contributor

@eulerfx eulerfx commented Mar 12, 2018

Adds support for the v11 protocol. More specifically, supports v5 of Fetch API and v3 of Produce API, both of which make use of the v2 message format (RecordBatch).

else
value ||| int64 (b <<< i)
let value = go 0L 0
(value >>> 1) ^^^ -(value &&& 1L)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Ah okay I think I see what I did wrong now. Kafka was never "doubling" anything, it was just zigzag encoding a signed int64. Sorry about that!

@eulerfx
Copy link
Contributor Author

eulerfx commented Mar 14, 2018

Addresses: #179

@eulerfx eulerfx merged commit e13d471 into jet:master Mar 14, 2018
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants