confluentinc kafka-javascript

Signed-off-by: Joe Bowbeer <[email protected]>

Author: joebowbeer

package-lock.json

@@ -29,7 +29,7 @@
     "build": "tsc --project tsconfig.build.json"
   },
   "devDependencies": {
-    "kafkajs": "^2.2.4"
+    "@confluentinc/kafka-javascript": "^1.7.0"
   },
   "dependencies": {
     "compare-versions": "^6.1.1",

packages/modules/kafka/package.json

@@ -84,17 +84,19 @@ describe("KafkaContainer", { timeout: 240_000 }, () => {
         })
         .start();
 
-      await assertMessageProducedAndConsumed(container, {
-        brokers: [`${container.getHost()}:${container.getMappedPort(9096)}`],
-        sasl: {
-          username: "app-user",
-          password: "userPassword",
-          mechanism: "scram-sha-512",
-        },
-        ssl: {
-          ca: [fs.readFileSync(path.resolve(certificatesDir, "kafka.client.truststore.pem"))],
+      await assertMessageProducedAndConsumed(
+        container,
+        {
+          brokers: [`${container.getHost()}:${container.getMappedPort(9096)}`],
+          ssl: true,
         },
-      });
+        {
+          "sasl.username": "app-user",
+          "sasl.password": "userPassword",
+          "sasl.mechanism": "scram-sha-512",
+          "ssl.ca.location": path.resolve(certificatesDir, "kafka.client.truststore.pem"),
+        }
+      );
       // }
     });
 
@@ -121,17 +123,19 @@ describe("KafkaContainer", { timeout: 240_000 }, () => {
         })
         .start();
 
-      await assertMessageProducedAndConsumed(container, {
-        brokers: [`${container.getHost()}:${container.getMappedPort(9096)}`],
-        sasl: {
-          username: "app-user",
-          password: "userPassword",
-          mechanism: "scram-sha-512",
-        },
-        ssl: {
-          ca: [fs.readFileSync(path.resolve(certificatesDir, "kafka.client.truststore.pem"))],
+      await assertMessageProducedAndConsumed(
+        container,
+        {
+          brokers: [`${container.getHost()}:${container.getMappedPort(9096)}`],
+          ssl: true,
         },
-      });
+        {
+          "sasl.username": "app-user",
+          "sasl.password": "userPassword",
+          "sasl.mechanism": "scram-sha-512",
+          "ssl.ca.location": path.resolve(certificatesDir, "kafka.client.truststore.pem"),
+        }
+      );
     });
 
     it(`should connect within Docker network`, async () => {