v0.5.0 · World

record-handler

A workload that receives Kafka batches on demand.

The provider owns polling, heartbeats, assignment, retries and commits. The workload holds no consumer resource, so instances can appear for active partitions and retire when the burst drains.

Exports

handler

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

since 0.2.0

Imports

types

Types shared by the producer and consumer interfaces.

since 0.2.0 I

producer

Binding-scoped Kafka publishing.

since 0.2.0