import { BaseEventProducer, DomainEventHandler, ExceptionHandler, KafkaConsumerConfig } from 'cm-libs-bootstrap';
import { KYCSchema } from 'cm-schema-event';
export declare function kycConsumerPlugin(options: KafkaConsumerConfig & {
    subscribeFunction: DomainEventHandler<KYCSchema.KYCDoneEventParams, unknown>;
    errorHandlerFunction: ExceptionHandler<KYCSchema.KYCDoneEventParams, unknown>;
}): {
    serverWillStart(): Promise<{
        drainServer(): Promise<void>;
    }>;
};
export declare class KYCEventProducer extends BaseEventProducer<KYCSchema.KYCDoneEventParams> {
    private static self;
    private constructor();
    static init(topics: string[]): KYCEventProducer;
    static get instance(): KYCEventProducer;
    static term(): Promise<void>;
}
export declare function kycProducerPlugin(options: {
    topics: string[];
}): {
    serverWillStart(): Promise<{
        serverWillStop(): Promise<void>;
    }>;
};