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

    Function createDenoSocketFactory

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

      Returns SocketFactory

      import { KafkaConnection } from "@qualithm/kafka-client"
      import { createDenoSocketFactory } from "@qualithm/kafka-client/deno-socket"

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