import { GenericObject } from '../../typings';
import BaseTransporter from './base';
import { KafkaClient, Producer, ConsumerGroup } from 'kafka-node';
export default class KafkaTransporter extends BaseTransporter {
    client: KafkaClient | null;
    producer: Producer | null;
    consumer: ConsumerGroup | null;
    constructor(options: any);
    connect(): Promise<void>;
    disconnect(): void;
    makeSubscriptions(topics: GenericObject[]): Promise<void>;
    send(topic: string, data: Buffer, { packet }: {
        packet: any;
    }): Promise<void>;
}