import { OnModuleInit, OnModuleDestroy } from '@nestjs/common';
import { ConfigService } from '@nestjs/config';
import { EventEmitter2 } from '@nestjs/event-emitter';
export declare class ConsumerService implements OnModuleInit, OnModuleDestroy {
    private configService;
    private eventEmitter;
    private readonly kafka;
    private readonly consumer;
    private readonly logger;
    private isConnected;
    constructor(configService: ConfigService, eventEmitter: EventEmitter2);
    onModuleInit(): Promise<void>;
    onModuleDestroy(): Promise<void>;
    private handleMessage;
    subscribeToTopic(topic: string): Promise<void>;
}