@qualithm/kafka-client - v0.1.6
    Preparing search index...

    Type Alias BatchConfig

    Batching configuration for the producer.

    When lingerMs is greater than 0, messages are accumulated and sent in batches to reduce the number of requests to the broker.

    type BatchConfig = {
        batchBytes?: number;
        lingerMs?: number;
    }
    Index

    Properties

    batchBytes?: number

    Maximum batch size in bytes per partition before triggering a flush.

    16384
    
    lingerMs?: number

    Maximum time in milliseconds to wait before flushing a batch. Set to 0 for no lingering (immediate send).

    0