import { Logger, OnModuleDestroy, OnModuleInit } from '@nestjs/common';
import { DiscoveryService, MetadataScanner, Reflector } from '@nestjs/core';
import { Consumer } from 'kafkajs';
import { KafkaConsumeOptions, KafkaModuleOptions } from './interface';
import { KafkaService } from './kafka.service';
export declare class KafkaConsumerService implements OnModuleInit, OnModuleDestroy {
    private readonly options;
    private readonly kafka;
    private readonly reflector;
    private readonly discoveryService;
    private readonly metadataScanner;
    logger: Logger;
    consumers: Consumer[];
    subscriber: Record<string, KafkaConsumeOptions>;
    constructor(options: KafkaModuleOptions, kafka: KafkaService, reflector: Reflector, discoveryService: DiscoveryService, metadataScanner: MetadataScanner);
    private getTarget;
    onModuleInit(): Promise<void>;
    onModuleDestroy(): Promise<void>;
}