6个版本 (稳定)
23.3.4 |
|
---|---|
23.3.4-rc1 |
|
23.3.1-rc4 |
|
1.1.0 | 2024年7月26日 |
0.0.1-dev+edeac7a3ef |
|
180 在 WebAssembly 中
每月115次 下载
40KB
648 行
Redpanda数据转换Rust SDK
此crate包含基于WebAssembly的Redpanda内联数据转换的SDK。
数据转换允许您在Redpanda中运行常见的数据流任务,如过滤、清理和转码。例如,您可能有一些需要您擦除信用卡号码或将JSON转换为Avro的消费者。
数据转换在Redpanda代理内部使用WebAssembly (Wasm) 引擎。一个Wasm函数作用于输入主题中的一个记录。您可以使用rpk transform
命令开发和管理工作转换。
请参阅examples/
以获取示例用法。
lib.rs
:
Redpanda数据转换Rust库。
数据转换允许您在Redpanda中运行常见的数据流任务,如过滤、清理和转码。例如,您可能有一些需要您擦除信用卡号码或将JSON转换为Avro的消费者。
数据转换在Redpanda代理内部使用WebAssembly (Wasm) 引擎。因此,转换必须通过--target=wasm32-wasi
编译为WebAssembly。一个Wasm函数作用于输入主题中的一个记录。您可以使用rpk transform
命令开发和管理工作转换。
此crate提供编写转换的框架。
on_record_written
:在记录写入输入主题后转换单个记录。写入的记录输出到目标主题。