/**
 * @fileoverview Direct (api-key) client manager — adds a native Kafka client to the
 * REST/Schema-Registry surfaces inherited from {@link BaseClientManager}.
 */
import { GlobalConfig, KafkaJS } from "@confluentinc/kafka-javascript";
import { type DirectConnectionConfig } from "../config/models.js";
import { BaseClientManager, type BaseClientManagerConfig } from "../confluent/base-client-manager.js";
import { type ClientManager } from "../confluent/client-manager.js";
export interface DirectClientManagerConfig extends BaseClientManagerConfig {
    kafka: GlobalConfig;
}
/**
 * Direct API-key client manager. Adds a native Kafka client (admin, producer, consumer)
 * authenticated via SASL/PLAIN on top of the REST clients in {@link BaseClientManager}.
 */
export declare class DirectClientManager extends BaseClientManager implements ClientManager {
    private readonly kafkaConfig;
    private readonly kafkaClient;
    private readonly adminClient;
    private readonly producer;
    constructor(config: DirectClientManagerConfig);
    /** @inheritdoc */
    getConsumer(sessionId?: string): Promise<KafkaJS.Consumer>;
    /** @inheritdoc */
    getKafkaClient(): KafkaJS.Kafka;
    /** @inheritdoc */
    getAdminClient(): Promise<KafkaJS.Admin>;
    /** @inheritdoc */
    getProducer(): Promise<KafkaJS.Producer>;
    /** @inheritdoc */
    getKafkaAdminClient(_clusterId?: string, _envId?: string): Promise<KafkaJS.Admin>;
    /** @inheritdoc */
    getKafkaProducer(_clusterId?: string, _envId?: string): Promise<KafkaJS.Producer>;
    /** @inheritdoc */
    buildKafkaConsumer(_clusterId?: string, _envId?: string, groupId?: string): Promise<KafkaJS.Consumer>;
    /** @inheritdoc */
    disconnect(): Promise<void>;
}
/**
 * Constructs a {@link DirectClientManager} from a single direct connection config.
 */
export declare function constructDirectClientManager(conn: DirectConnectionConfig): DirectClientManager;
//# sourceMappingURL=direct-client-manager.d.ts.map