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; // process.env.KAFKA_REGISTRY,
    brokers: string[] | BrokersFunction; // process.env.KAFKA_BROKERS?.split(';'),
    ca?: string | Buffer | Array<string | Buffer>; // process.env.KAFKA_CERT,
    cert?: string | Buffer | Array<string | Buffer>; // process.env.KAFKA_KEY,
    key?: string | Buffer | Array<Buffer | KeyObject>; // process.env.KAFKA_CA_CERT
};