Skip to content

Connectum API Reference / @connectum/events-kafka / types / KafkaLifecycleCallbacks

Interface: KafkaLifecycleCallbacks ​

Defined in: types.ts:255

Callbacks for the lifecycle of the Kafka adapter.

Properties ​

onLifecycle? ​

readonly optional onLifecycle?: (event) => void | Promise<void>

Defined in: types.ts:261

Called for every KafkaLifecycleEvent. It should not throw: a thrown exception or a rejected returned promise is isolated and reported as a lifecycle-error event, and a failure while handling that one is dropped. A returned promise is not awaited.

Parameters ​

event ​

KafkaLifecycleEvent

Returns ​

void | Promise<void>