From e9d1c8675bc880387b471ee95ef03e56f50710ce Mon Sep 17 00:00:00 2001
From: Joe Bowbeer <joe.bowbeer@gmail.com>
Date: Tue, 16 Dec 2025 09:52:09 -0800
Subject: [PATCH] chore: export SaslSslListenerOptions

Signed-off-by: Joe Bowbeer <joe.bowbeer@gmail.com>
---
 packages/modules/kafka/src/index.ts           |  2 +-
 .../kafka/src/kafka-container-7.test.ts       | 22 ++++++++++---------
 .../kafka/src/kafka-container-latest.test.ts  | 13 ++++++-----
 3 files changed, 20 insertions(+), 17 deletions(-)

diff --git a/packages/modules/kafka/src/index.ts b/packages/modules/kafka/src/index.ts
index 651afdebb..6747bfaa2 100644
--- a/packages/modules/kafka/src/index.ts
+++ b/packages/modules/kafka/src/index.ts
@@ -1 +1 @@
-export { KafkaContainer, StartedKafkaContainer } from "./kafka-container";
+export { KafkaContainer, SaslSslListenerOptions, StartedKafkaContainer } from "./kafka-container";
diff --git a/packages/modules/kafka/src/kafka-container-7.test.ts b/packages/modules/kafka/src/kafka-container-7.test.ts
index 4e28dc880..fd741b5d4 100644
--- a/packages/modules/kafka/src/kafka-container-7.test.ts
+++ b/packages/modules/kafka/src/kafka-container-7.test.ts
@@ -1,5 +1,5 @@
-import fs from "fs";
-import path from "path";
+import fs from "node:fs";
+import path from "node:path";
 import { GenericContainer, Network } from "testcontainers";
 import { KafkaContainer } from "./kafka-container";
 import { assertMessageProducedAndConsumed } from "./test-helper";
@@ -89,12 +89,13 @@ describe("KafkaContainer", { timeout: 240_000 }, () => {
         {
           brokers: [`${container.getHost()}:${container.getMappedPort(9096)}`],
           ssl: true,
+          sasl: {
+            mechanism: "scram-sha-512",
+            username: "app-user",
+            password: "userPassword",
+          },
         },
         {
-          "sasl.mechanism": "SCRAM-SHA-512",
-          "sasl.username": "app-user",
-          "sasl.password": "userPassword",
-          "security.protocol": "sasl_ssl",
           "ssl.ca.location": path.resolve(certificatesDir, "kafka.client.truststore.pem"),
         }
       );
@@ -129,12 +130,13 @@ describe("KafkaContainer", { timeout: 240_000 }, () => {
         {
           brokers: [`${container.getHost()}:${container.getMappedPort(9096)}`],
           ssl: true,
+          sasl: {
+            mechanism: "scram-sha-512",
+            username: "app-user",
+            password: "userPassword",
+          },
         },
         {
-          "sasl.mechanism": "SCRAM-SHA-512",
-          "sasl.username": "app-user",
-          "sasl.password": "userPassword",
-          "security.protocol": "sasl_ssl",
           "ssl.ca.location": path.resolve(certificatesDir, "kafka.client.truststore.pem"),
         }
       );
diff --git a/packages/modules/kafka/src/kafka-container-latest.test.ts b/packages/modules/kafka/src/kafka-container-latest.test.ts
index 888fbdb30..899bb96b7 100644
--- a/packages/modules/kafka/src/kafka-container-latest.test.ts
+++ b/packages/modules/kafka/src/kafka-container-latest.test.ts
@@ -1,5 +1,5 @@
-import fs from "fs";
-import path from "path";
+import fs from "node:fs";
+import path from "node:path";
 import { GenericContainer, Network } from "testcontainers";
 import { getImage } from "../../../testcontainers/src/utils/test-helper";
 import { KafkaContainer, SaslSslListenerOptions } from "./kafka-container";
@@ -60,12 +60,13 @@ describe("KafkaContainer", { timeout: 240_000 }, () => {
       {
         brokers: [`${container.getHost()}:${container.getMappedPort(9096)}`],
         ssl: true,
+        sasl: {
+          mechanism: "scram-sha-512",
+          username: "app-user",
+          password: "userPassword",
+        },
       },
       {
-        "sasl.mechanism": "SCRAM-SHA-512",
-        "sasl.username": "app-user",
-        "sasl.password": "userPassword",
-        "security.protocol": "sasl_ssl",
         "ssl.ca.location": path.resolve(certificatesDir, "kafka.client.truststore.pem"),
       }
     );