From a2e4ab7d46341439eca2189f6393f92989a9324c Mon Sep 17 00:00:00 2001
From: Francis Cao <franciscao@gmail.com>
Date: Mon, 15 Apr 2024 13:44:16 -0700
Subject: [PATCH] update kafka connection to upstash config

---
 src/lib/kafka.ts | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git a/src/lib/kafka.ts b/src/lib/kafka.ts
index 10326888..da38baa4 100644
--- a/src/lib/kafka.ts
+++ b/src/lib/kafka.ts
@@ -17,14 +17,9 @@ function getClient() {
   const ssl: { ssl?: tls.ConnectionOptions | boolean; sasl?: SASLOptions | Mechanism } =
     username && password
       ? {
-          ssl: {
-            checkServerIdentity: () => undefined,
-            ca: [process.env.CA_CERT],
-            key: process.env.CLIENT_KEY,
-            cert: process.env.CLIENT_CERT,
-          },
+          ssl: true,
           sasl: {
-            mechanism: 'plain',
+            mechanism: 'scram-sha-256',
             username,
             password,
           },