23.1.21 • Published 5 months ago
@redpanda-data/wasm-api v23.1.21
redpanda wasm-api
Redpanda coprocessing client library for nodejs
How to use?
- Simply include the library and create your own instance of the SimpleTransform class.
const wasmJs = const {
SimpleTransform,
} = require("@redpanda-data/wasm-api");
const transform = new SimpleTransform();
- Specify what topics you want your script to consume from:
transform.subscribe(["my-topic", PolicyInjection.Stored]);
- And write your custom transform logic that may filter or transform records in any way you'd like.
transform.processRecord((recordBatch) => {
return Promise.resolve(new Map(....));
});
Whats the expected output?
Use the map returned from the processRecord method to determine what output topics you'd like to produce onto. For example if the recordBatch arrived from 'my-topic' and your Map contains a single key 'Foo', the transformed recordBatch will be produced onto a materialized topic named 'my-topic.$Foo$'. Materialized topics share all topic attributes with its source topic.
23.1.21
5 months ago
23.1.21-rc2
5 months ago
23.1.21-rc1
5 months ago
23.1.16-rc1
9 months ago
23.1.18-rc1
8 months ago
23.1.18-rc2
8 months ago
23.1.20
7 months ago
23.1.15
9 months ago
23.1.16
9 months ago
23.1.6-rc1
8 months ago
23.1.14
10 months ago
23.1.19
7 months ago
23.1.15-rc1
9 months ago
23.1.17
8 months ago
23.1.18
8 months ago
23.1.17-rc1
8 months ago
23.1.20-rc1
7 months ago
23.1.19-rc1
7 months ago
23.1.19-rc2
7 months ago
23.1.14-rc1
10 months ago
23.1.19-rc3
7 months ago
22.2.3
2 years ago