import { Cluster } from '../cluster';
import { Message } from '../types';
import { ProducerState } from './producer-state';
type ProducerBufferOptions = {
    nodeId: number;
    maxBatchSize: number;
    cluster: Cluster;
    state: ProducerState;
};
export declare class ProducerBuffer {
    private options;
    private buffer;
    private head;
    private isFlushing;
    constructor(options: ProducerBufferOptions);
    enqueue(messages: Message[]): Promise<void>;
    private flush;
    private compactBuffer;
}
export {};