v0.3.0 · Interface
producer
Producing records, including the idempotent and transactional paths.
Every function is async
Including the ones that only read local state — which is not how they
would be written for a native
implementation. A host component plugin's capabilities are installed on a
caller's linker as concurrent host functions, and a sync func fails to bind
there with "type mismatch with async". One sync function is therefore enough
to make the whole interface unservable from a component, and this package's
host-plugin world describes exactly that deployment. An async lift costs a
native implementation nothing — the body returns without suspending — so this
is the version that both kinds of provider can serve.
Type Aliases
T
config-entry
TA client configuration property.
error
TAn error, with librdkafka's own classification attached.
produce-record
TA record to produce.
produce-ack
TWhere a produced record landed.
partition-offset
TA position in a partition.
partition
TA partition index within a topic.
watermarks
The low and high watermarks of a partition.