update kafka connection to upstash config

2025-02-01 12:29:35 +01:00 · 2024-04-15 13:44:16 -07:00 · 2024-04-15 13:44:16 -07:00 · a2e4ab7d46
commit a2e4ab7d46
parent 1579beef5b
1 changed files with 2 additions and 7 deletions
--- 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,
          },