- Preparing search index...
- The search index is not available
biorate
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