【文件属性】:
文件名称:kafka-serde:Rust对Kafka协议的serde实现
文件大小:17KB
文件格式:ZIP
更新时间:2021-05-22 10:15:22
Rust
卡夫卡·塞德
Rust针对Kafka协议的serde实现。
这使您可以序列化和反序列化kafka有效负载。 它可以用作原生Rust Kafka客户端的构建基块。
用法
序列化kafka请求标头:
use serde :: Serialize;
use std :: io :: {Write, Cursor};
#[derive(Serialize, Debug)]
struct RequestHeader {
api_key: i16 ,
api_version: i16 ,
correlation_id: i32 ,
client_id: & ' static str ,
}
let req = RequestHeader {
api_key: 0 ,
api_version: 0 ,
correlation_id: 1 ,
【文件预览】:
kafka-serde-main
----LICENSE-MIT(1023B)
----Cargo.toml(536B)
----.github()
--------PULL_REQUEST_TEMPLATE.md(540B)
----LICENSE-3rdparty.csv(377B)
----src()
--------ser.rs(13KB)
--------error.rs(3KB)
--------de.rs(14KB)
--------lib.rs(1KB)
----.circleci()
--------config.yml(4KB)
----LICENSE-APACHE(11KB)
----CONTRIBUTING.md(3KB)
----README.md(1KB)
----.gitignore(320B)