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

    Type Alias SocketConnectOptions

    Options for establishing a socket connection.

    type SocketConnectOptions = {
        host: string;
        onClose: () => void;
        onData: (data: Uint8Array) => void;
        onError: (error: Error) => void;
        port: number;
        tls?: TlsConfig;
    }
    Index

    Properties

    host: string

    Hostname or IP address of the broker.

    onClose: () => void

    Called when the socket is closed (either side).

    onData: (data: Uint8Array) => void

    Called when data arrives from the broker.

    onError: (error: Error) => void

    Called when a socket error occurs.

    port: number

    Port number of the broker.

    tls?: TlsConfig

    TLS configuration. When provided with enabled: true, the connection uses TLS.