import type { Consumer } from 'kafkajs';
import * as z from 'zod';
import type { Api } from '../api';
declare const InputMessage: z.ZodUnion<readonly [z.ZodObject<{
    topic: z.ZodLiteral<"finished-processing">;
    payload: z.ZodObject<{
        kafkaMessageOffset: z.ZodString;
    }, z.core.$strip>;
}, z.core.$strip>, z.ZodObject<{
    topic: z.ZodLiteral<"force-reset">;
}, z.core.$strip>]>;
export declare const SourceKafka: (api: Api) => {
    new (config: any): {
        consumer: Promise<Consumer>;
        /** Used to orchestrate consumer retry */
        isDestroying: boolean;
        kafkaPendingProcessing: {
            messageOffset: string;
            resolve: VoidFunction;
            reject: (err: Error) => void;
        } | null;
        runConsumerWithRetry({ topic }: {
            topic: string;
        }): void;
        runConsumer({ topic }: {
            topic: string;
        }): Promise<void>;
        setStatus(status: "connected" | "waiting" | "connecting"): void;
        /**
         * Input is responsible for resolving promise that kafka consumer is waiting for
         */
        onInput(message: z.infer<typeof InputMessage>): void;
        onDestroy(): Promise<void>;
        api: Api;
        nodeConfig: unknown;
        messageZod: z.ZodUnion<readonly [z.ZodObject<{
            topic: z.ZodLiteral<"finished-processing">;
            payload: z.ZodObject<{
                kafkaMessageOffset: z.ZodString;
            }, z.core.$strip>;
        }, z.core.$strip>, z.ZodObject<{
            topic: z.ZodLiteral<"force-reset">;
        }, z.core.$strip>]>;
        getBaseUrls(): Promise<z.core.output<typeof import("../node").BaseUrlsConfig>>;
        getNodeEnvConfig(): import("../node").NodeEnvConfig;
        sendBuilder(inputMessage: import("../types").NodeMessage<any>): import("../node").SendBuilder;
        handleMaybePromise<T>(maybePromiseCb: () => (T | Promise<T>), done: (err?: Error) => void): void;
    };
};
export {};