import { type produceRequest } from "https://dotland.deno.dev/x/kafkasaur@v0.0.7/index.d.ts";
Properties
request: { topicData: Array<{ topic: string; partitions: Array<{ partition: number; firstSequence?: number; messages: Message[]; }>; }>; transactionalId?: string; producerId?: number; producerEpoch?: number; acks?: number; timeout?: number; compression?: CompressionTypes; }