Create a SocketFactory that uses Bun.connect() for TCP/TLS.
Bun.connect()
Optional
Create a TCP client that connects to a server via a TCP socket
Create a TCP client that connects to a server via a unix socket
import { KafkaConnection } from "@qualithm/kafka-client"import { createBunSocketFactory } from "@qualithm/kafka-client/bun-socket"const connection = new KafkaConnection({ host: "localhost", port: 9092, socketFactory: createBunSocketFactory(),}) Copy
import { KafkaConnection } from "@qualithm/kafka-client"import { createBunSocketFactory } from "@qualithm/kafka-client/bun-socket"const connection = new KafkaConnection({ host: "localhost", port: 9092, socketFactory: createBunSocketFactory(),})
Create a SocketFactory that uses
Bun.connect()for TCP/TLS.