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