/// <reference types="node" />
import { StatsD } from 'hot-shots';
import { Producer, ProducerRecord } from 'kafkajs';
import { PluginsServerConfig } from '../../types';
export declare class KafkaProducerWrapper {
    producer: Producer;
    statsd: StatsD | undefined;
    lastFlushTime: number;
    currentBatch: Array<ProducerRecord>;
    currentBatchSize: number;
    flushFrequencyMs: number;
    maxQueueSize: number;
    maxBatchSize: number;
    flushInterval: NodeJS.Timeout;
    constructor(producer: Producer, statsd: StatsD | undefined, serverConfig: PluginsServerConfig);
    queueMessage(kafkaMessage: ProducerRecord): Promise<void>;
    flush(append?: ProducerRecord): Promise<void>;
    private getMessageSize;
}