import { MessageConsumerKafkaJs } from "@dugongjs/kafkajs";
import { type OnModuleDestroy } from "@nestjs/common";
import type { ConsumerConfig, ConsumerRunConfig, ConsumerSubscribeTopics } from "kafkajs";
import { KafkaService } from "../kafka/kafka.service.js";
export declare class MessageConsumerKafkaJsService extends MessageConsumerKafkaJs implements OnModuleDestroy {
    constructor(kafkaService: KafkaService, consumerConfig?: ConsumerConfig, consumerSubscribeTopics?: ConsumerSubscribeTopics, consumerRunConfig?: ConsumerRunConfig);
    onModuleDestroy(): Promise<void>;
}