import * as valleyed from 'valleyed';
import { E as Events } from '../../../overrides-6Hxg764S.js';
import { EventBus, StreamOptions, Stream } from '../../index.js';

declare const kafkaConfigPipe: () => valleyed.Pipe<{
    brokers: string[];
    ssl: boolean | undefined;
    sasl: {
        mechanism: "plain";
        username: string;
        password: string;
    } | undefined;
    clientId: string | undefined;
}, {
    brokers: string[];
    ssl: boolean | undefined;
    sasl: {
        mechanism: "plain";
        username: string;
        password: string;
    } | undefined;
    clientId: string | undefined;
}>;
declare const KafkaEventBus_base: (abstract new (validated: {
    brokers: string[];
    ssl: boolean | undefined;
    sasl: {
        mechanism: "plain";
        username: string;
        password: string;
    } | undefined;
    clientId: string | undefined;
}) => EventBus & {
    readonly config: {
        brokers: string[];
        ssl: boolean | undefined;
        sasl: {
            mechanism: "plain";
            username: string;
            password: string;
        } | undefined;
        clientId: string | undefined;
    };
}) & {
    readonly Config: {
        brokers: string[];
        ssl: boolean | undefined;
        sasl: {
            mechanism: "plain";
            username: string;
            password: string;
        } | undefined;
        clientId: string | undefined;
    };
    create<This extends Function & {
        prototype: any;
    }>(this: This, input: {
        brokers: string[];
        ssl?: boolean | undefined;
        sasl?: {
            mechanism: "plain";
            username: string;
            password: string;
        } | undefined;
        clientId?: string | undefined;
    }, ...args: ConstructorParameters<This & (abstract new (...args: any[]) => any)> extends [{
        brokers: string[];
        ssl: boolean | undefined;
        sasl: {
            mechanism: "plain";
            username: string;
            password: string;
        } | undefined;
        clientId: string | undefined;
    }, ...infer R] ? R : never): This["prototype"];
};
declare class KafkaEventBus extends KafkaEventBus_base {
    #private;
    protected constructor(config: typeof KafkaEventBus.Config);
    stream<Event extends Events[keyof Events]>(topicName: Event['topic'], options?: Partial<StreamOptions>): Stream<Event['data']>;
}

export { KafkaEventBus, kafkaConfigPipe };