import Piscina from '@posthog/piscina';
import { Hub, Queue, WorkerMethods } from '../../types';
export declare class KafkaQueue implements Queue {
    private pluginsServer;
    private piscina;
    private kafka;
    private consumer;
    private wasConsumerRan;
    private workerMethods;
    constructor(pluginsServer: Hub, piscina: Piscina, workerMethods: WorkerMethods);
    private eachMessage;
    private eachBatch;
    start(): Promise<void>;
    pause(): Promise<void>;
    resume(): void;
    isPaused(): boolean;
    stop(): Promise<void>;
    private static buildConsumer;
}