/**
 * E2E Test Runner - Kafka Adapter
 *
 * Apache Kafka operations using kafkajs
 */
import type { AdapterConfig, AdapterContext, AdapterStepResult, Logger } from '../types';
import { BaseAdapter } from './base.adapter';
export declare class KafkaAdapter extends BaseAdapter {
    private kafka;
    private producer;
    constructor(config: AdapterConfig, logger: Logger);
    get name(): string;
    connect(): Promise<void>;
    disconnect(): Promise<void>;
    execute(action: string, params: Record<string, unknown>, ctx: AdapterContext): Promise<AdapterStepResult>;
    healthCheck(): Promise<boolean>;
    private produceMessage;
    private consumeMessages;
    private waitForMessage;
    private matchesFilter;
    private getNestedValue;
}
//# sourceMappingURL=kafka.adapter.d.ts.map