Skip to main content
Deno 2 is finally here 🎉️
Learn more
Latest
variable default
import { default } from "https://deno.land/x/kafkasaur@v0.0.7/src/consumer/filterAbortedMessages.ts";

Remove messages marked as aborted according to the aborted transactions list.

Start of an aborted transaction is determined by message offset. End of an aborted transaction is determined by control messages.

type

(unnamed 0: any) => unknown