import { O as OffsetDeduper, S as SetHasConsumedParams, C as CheckIfAlreadyConsumedParams } from '../batcher-498abef4.js';
import 'kafkajs';

interface FsOffsetDeduperConstructorOptions {
    filepath: string;
}
declare class FsOffsetDeduper implements OffsetDeduper {
    store: {
        [topic: string]: {
            [partition: number]: {
                offsets: string[];
                commitOffset: string;
            };
        };
    };
    private filePath;
    constructor(opts?: FsOffsetDeduperConstructorOptions);
    private save;
    load(): void;
    setHasConsumed({ messages, commitOptions }: SetHasConsumedParams): Promise<any>;
    checkIfAlreadyConsumed({ topic, partition, offset }: CheckIfAlreadyConsumedParams): Promise<boolean>;
}

export { FsOffsetDeduper };