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

    Function createBunSocketFactory

    • Create a SocketFactory that uses Bun.connect() for TCP/TLS.

      Parameters

      • Optionalconnect: {
            <Data = undefined>(
                options: TCPSocketConnectOptions<Data>,
            ): Promise<Socket<Data>>;
            <Data = undefined>(options: UnixSocketOptions<Data>): Promise<Socket<Data>>;
        }
          • <Data = undefined>(
                options: TCPSocketConnectOptions<Data>,
            ): Promise<Socket<Data>>
          • Create a TCP client that connects to a server via a TCP socket

            Type Parameters

            • Data = undefined

            Parameters

            • options: TCPSocketConnectOptions<Data>

            Returns Promise<Socket<Data>>

          • <Data = undefined>(options: UnixSocketOptions<Data>): Promise<Socket<Data>>
          • Create a TCP client that connects to a server via a unix socket

            Type Parameters

            • Data = undefined

            Parameters

            • options: UnixSocketOptions<Data>

            Returns Promise<Socket<Data>>

      Returns SocketFactory

      import { KafkaConnection } from "@qualithm/kafka-client"
      import { createBunSocketFactory } from "@qualithm/kafka-client/bun-socket"

      const connection = new KafkaConnection({
      host: "localhost",
      port: 9092,
      socketFactory: createBunSocketFactory(),
      })