This package has been deprecated

Author message:

Package no longer supported. Contact Support at https://www.npmjs.com/support for more info.

@redpanda-data/wasm-api

23.1.21 • Public • Published

redpanda wasm-api

Redpanda coprocessing client library for nodejs

How to use?

  1. 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();
  1. Specify what topics you want your script to consume from:
transform.subscribe(["my-topic", PolicyInjection.Stored]);
  1. 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.

Readme

Keywords

none

Package Sidebar

Install

npm i @redpanda-data/wasm-api

Weekly Downloads

0

Version

23.1.21

License

ISC

Unpacked Size

5.41 kB

Total Files

3

Last publish

Collaborators

  • andres-aristizabal
  • dan.redpanda
  • frankmanno
  • malinskibeniamin
  • mateo.redpanda
  • redpanda-bot
  • sago2k8
  • weeco-redpanda