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

Interface: KafkaConsumerOptions

Defined in: index.ts:58

Properties

brokers

brokers: string[]

Defined in: index.ts:59

---

fromBeginning?

optional fromBeginning?: boolean

Defined in: index.ts:65

---

groupId

groupId: string

Defined in: index.ts:61

Grupo de consumidores (cada microservicio el suyo).

---

handler

handler: (event) => Promise<void>

Defined in: index.ts:64

Si lanza, el mensaje no se confirma y kafkajs lo reintenta.

Parameters

event

CloudEvent

Returns

Promise<void>

---

kafka?

optional kafka?: Omit<KafkaConfig, "brokers" | "clientId">

Defined in: index.ts:68

Opciones de kafkajs (SSL, SASL, logLevel, logCreator para mandar sus logs a tu logger).

---

onError?

optional onError?: (error, event) => void

Defined in: index.ts:66

Parameters

error

unknown

event

CloudEvent<unknown> | undefined

Returns

void

---

topics?

optional topics?: string[]

Defined in: index.ts:62