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

    Function createNodeSocketFactory

    • Create a SocketFactory that uses Node.js net/tls for TCP/TLS.

      Returns SocketFactory

      import { KafkaConnection } from "@qualithm/kafka-client"
      import { createNodeSocketFactory } from "@qualithm/kafka-client/node-socket"

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