Type alias IKafkaJSConsumerConfig
IKafkaJSConsumerConfig: IConnectorConfig & { concurrency?: number; global: KafkaConfig; options: ConsumerConfig; runConfig?: ConsumerRunConfig; subscribe?: ConsumerSubscribeTopics; } Type declaration
Optional concurrency?: number
global: KafkaConfig
options: ConsumerConfig
Optional runConfig?: ConsumerRunConfig
Optional subscribe?: ConsumerSubscribeTopics