Create a SocketFactory that uses Deno.connect() / Deno.connectTls() for TCP/TLS.
Deno.connect()
Deno.connectTls()
import { KafkaConnection } from "@qualithm/kafka-client"import { createDenoSocketFactory } from "@qualithm/kafka-client/deno-socket"const connection = new KafkaConnection({ host: "localhost", port: 9092, socketFactory: createDenoSocketFactory(),}) Copy
import { KafkaConnection } from "@qualithm/kafka-client"import { createDenoSocketFactory } from "@qualithm/kafka-client/deno-socket"const connection = new KafkaConnection({ host: "localhost", port: 9092, socketFactory: createDenoSocketFactory(),})
Create a SocketFactory that uses
Deno.connect()/Deno.connectTls()for TCP/TLS.