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

    Type Alias CompressionProvider

    Compression/decompression interface for record batch data.

    type CompressionProvider = {
        compress: (data: Uint8Array) => Uint8Array;
        decompress: (data: Uint8Array) => Uint8Array;
    }
    Index

    Properties

    Properties

    compress: (data: Uint8Array) => Uint8Array

    Compress data synchronously.

    decompress: (data: Uint8Array) => Uint8Array

    Decompress data synchronously.