/// <reference types="node" />
/// <reference types="node" />
import type { BrokersFunction, ProducerRecord, RecordMetadata } from 'kafkajs';
import { KeyObject } from 'tls';
export type KafkaConnection = {
    send: (record: ProducerRecord) => Promise<RecordMetadata[]>;
    encode: (payload: any) => Promise<Buffer>;
};
export type KafkaConnectionMap = Map<string, KafkaConnection>;
export type KafkaConnectionCredentials = {
    registry: string;
    brokers: string[] | BrokersFunction;
    ca?: string | Buffer | Array<string | Buffer>;
    cert?: string | Buffer | Array<string | Buffer>;
    key?: string | Buffer | Array<Buffer | KeyObject>;
};