Type alias IRDKafkaConsumerStreamConfig

IRDKafkaConsumerStreamConfig: IConnectorConfig & {
    batch?: boolean;
    buffer?: number;
    concurrency?: number;
    delay?: number;
    global: ConsumerGlobalConfig;
    stream: ReadStreamOptions;
    topic: ConsumerTopicConfig;
}

Type declaration

  • Optional batch?: boolean
  • Optional buffer?: number
  • Optional concurrency?: number
  • Optional delay?: number
  • global: ConsumerGlobalConfig
  • stream: ReadStreamOptions
  • topic: ConsumerTopicConfig

Generated using TypeDoc