Create a SocketFactory that uses Node.js net/tls for TCP/TLS.
net
tls
import { KafkaConnection } from "@qualithm/kafka-client"import { createNodeSocketFactory } from "@qualithm/kafka-client/node-socket"const connection = new KafkaConnection({ host: "localhost", port: 9092, socketFactory: createNodeSocketFactory(),}) Copy
import { KafkaConnection } from "@qualithm/kafka-client"import { createNodeSocketFactory } from "@qualithm/kafka-client/node-socket"const connection = new KafkaConnection({ host: "localhost", port: 9092, socketFactory: createNodeSocketFactory(),})
Create a SocketFactory that uses Node.js
net/tlsfor TCP/TLS.