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

Generated using TypeDoc