cosmonic:kafka

A workload that produces.

A long-lived consumer service.

A long-lived read-process-write service.

The Kafka capability implemented as a wasmCloud host component plugin.

A workload that is given records rather than reading them.

Types shared by the producer and consumer interfaces.

Consuming records, with and without consumer-group coordination.

Receiving records that a provider pushed, rather than reading a stream.

Producing records, including the idempotent and transactional paths.