import { IMessageQueueService } from "../interfaces";
import { Consumer, ConsumerConfig, ConsumerSubscribeTopics, Kafka, KafkaConfig, Producer, ProducerConfig, ConsumerRunConfig, ProducerRecord, TopicPartitionOffsetAndMetadata } from "kafkajs";
export declare class KafkaService implements IMessageQueueService {
    protected _kafka: Kafka;
    protected _producer: Producer;
    protected _consumer: Consumer;
    get producer(): Producer;
    get consumer(): Consumer;
    constructor(config: KafkaConfig);
    initProducer(config?: ProducerConfig): Promise<void>;
    initConsumer(config?: ConsumerConfig): Promise<void>;
    listen(subscribeConfig: ConsumerSubscribeTopics, runConfig: ConsumerRunConfig): Promise<void>;
    publish(record: ProducerRecord): Promise<void>;
    commitOffsets(data: TopicPartitionOffsetAndMetadata[]): Promise<void>;
}