kafka-protocol-rs
kafka-protocol-rs copied to clipboard
tychedelia
Rust Kafka protocol
closes https://github.com/tychedelia/kafka-protocol-rs/issues/114 closes https://github.com/tychedelia/kafka-protocol-rs/issues/54 - All raft/zk specific messages are removed in 4.0 kafka 4.0 removes a few versions/message types. This results in a few complications. ## 1. The `fields`...
Hey 👋 I run into a problem with parsing ApiVersions response. My Kafka Server supports ApiVersions v0-v3, but my client supports v0-v4. When it connects to the server, it uses...
I am using the crate to construct client requests. Requests in themselves don't generate the appropriate headers (RequestHeader does), so I am adding those myself. To do that, I am...
I messed up with the repo so I decided to recreate this pull request from scratch. Basically adding an Iterator support to browse the records using the RecordBatchDecoder
Hello! I'm wondering if there's any way to avoid a double-copy I'm having to do when encoding produce requests. Currently I am creating a new `BytesMut` to pass to `RecordBatchEncoder::encode`,...
I am currently doing this: ``` let api_key = ApiKey::try_from(buf.peek_bytes(0..2).get_i16()) .map_err(|_| anyhow::Error::msg("Unknown API key"))?; let api_version = buf.peek_bytes(2..4).get_i16(); let header_version = api_key.request_header_version(api_version); let correlation_id = RequestHeader::decode(&mut buf, header_version)?.correlation_id; let request...