Documentation / @tenancy-node/transport-kafka / consumeKafka

Function: consumeKafka()

consumeKafka(options): Promise<{ stop: Promise<void>; }>

Defined in: index.ts:72

Consume eventos: el offset se confirma solo después de que el handler termina bien.

Parameters

options

KafkaConsumerOptions

Returns

Promise<{ stop: Promise<void>; }>