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

interface RedisOffsetDeduperConstructorOptions {
    redisClient: any;
    namespace: string;
}
declare class RedisOffsetDeduper implements OffsetDeduper {
    /**
     * ioredis client
     */
    redisClient: any;
    /**
     * base prefix for redis sets
     */
    namespace: string;
    constructor(opts: RedisOffsetDeduperConstructorOptions);
    private getPrefixedKey;
    setHasConsumed({ messages, commitOptions }: SetHasConsumedParams): Promise<any>;
    checkIfAlreadyConsumed({ topic, partition, offset }: CheckIfAlreadyConsumedParams): Promise<boolean>;
}

export { RedisOffsetDeduper };