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
Description
Configuration for the KafkaJS consumer.