import { type KafkaReader } from "https://deno.land/x/kafkagosaur@v0.0.6/reader.ts";
Properties
commitMessages: (msgs: KafkaReadMessage[]) => Promise<void>
Commits the list of messages passed as argument.
fetchMessage: () => Promise<KafkaReadMessage>
Reads and return the next message. Does not commit offsets automatically
when using consumer groups. Use commitMessages
to commit the offset.
readMessage: () => Promise<KafkaReadMessage>
Reads and return the next message. If consumer groups are used, readMessage
will automatically commit the offset when called. Note that this could result
in an offset being committed before the message is fully processed.
If more fine grained control of when offsets are committed is required, it
is recommended to use fetchMessage
with commitMessages
instead.