interface SourceOptions {
    logger?: LoggerInstance;
    postConsumeOptions?: PostConsumeOptions;
    qos?: number;
    readableOptions?: ReadableOptions;
    retryOptions?: RetryOptions;
}

Properties

Debug logger for development and deep troubleshooting

postConsumeOptions?: PostConsumeOptions

Post consume operations options

qos?: number

Indicates the quality of service for the job, indeed this indicate the number of sinks that must be successfully processed to consider the job as successfully processed

readableOptions?: ReadableOptions

Readable streams options

retryOptions?: RetryOptions

Options for job retry operations