/// <reference types="node" />
import { ConsumerGroupStream, Message } from 'kafka-node';
import { Transform, TransformCallback } from 'stream';
export declare class ConsumerProgressTransform extends Transform {
    private consumerStream;
    private progress;
    constructor(consumerStream: ConsumerGroupStream);
    loadPartitions(topic: string): Promise<string[]>;
    initPartionProgress(topic: string): Promise<void>;
    updateProgress(message: Message): void;
    totalProgress(): number;
    totalCount(): number;
    _transform(message: Message, encoding: string, callback: TransformCallback): Promise<void>;
}