method EventLogAdapter.consume
EventLogAdapter.consume<T>(
topic: string,
consumerGroup: string,
onBatch: (batch: EventBatch<T, Cursor>) => Promisable<void>,
onError: (error: EventLogConsumeFailed) => Promisable<void>,
options?: ConsumeOptions<Cursor>
): { close: () => Promise<void>; }

Consume events from a topic.

Type Parameters

Parameters

topic: string
consumerGroup: string
onBatch: (batch: EventBatch<T, Cursor>) => Promisable<void>
onError: (error: EventLogConsumeFailed) => Promisable<void>
optional
options: ConsumeOptions<Cursor>

Return Type

{ close: () => Promise<void>; }

Usage

import { type EventLogAdapter } from ".";