class Runner
extends EventEmitter
import { Runner } from "https://deno.land/x/kafkasaur@v0.0.7/src/consumer/runner.ts";
Constructors
new
Runner(unnamed 0: RunnerOptions)Properties
eachBatch: null | ((payload: EachBatchPayload) => Promise<void>)
eachMessage: null | ((payload: EachMessagePayload) => Promise<void>)
logger: Logger
Methods
commitOffsets(offsets: any)
fetch()
join()
processEachBatch(batch: any)
processEachMessage(batch: any)
start()
stop()