method KafkaConnector.connect
KafkaConnector.connect(): Promise<EventLogAdapter<KafkaCursor>>

Return Type

Promise<EventLogAdapter<KafkaCursor>>

Usage

import { type KafkaConnector } from ".";