diff --git a/packages/modules/kafka/src/kafka-container-7.test.ts b/packages/modules/kafka/src/kafka-container-7.test.ts index fd741b5d4..cedffc668 100644 --- a/packages/modules/kafka/src/kafka-container-7.test.ts +++ b/packages/modules/kafka/src/kafka-container-7.test.ts @@ -18,6 +18,14 @@ describe("KafkaContainer", { timeout: 240_000 }, () => { await using container = await new KafkaContainer(IMAGE).start(); await assertMessageProducedAndConsumed(container); + + const { exitCode } = await container.exec([ + "sh", + "-c", + "test -f /tmp/testcontainers_start.sh && test ! -f /testcontainers_start.sh", + ]); + + expect(exitCode).toBe(0); }); it("should connect using in-built zoo-keeper and custom network", async () => { diff --git a/packages/modules/kafka/src/kafka-container.ts b/packages/modules/kafka/src/kafka-container.ts index 0cbfa98b8..d93508d46 100644 --- a/packages/modules/kafka/src/kafka-container.ts +++ b/packages/modules/kafka/src/kafka-container.ts @@ -19,7 +19,7 @@ const KAFKA_BROKER_PORT = 9092; const KAFKA_CONTROLLER_PORT = 9094; const DEFAULT_ZOOKEEPER_PORT = 2181; const DEFAULT_CLUSTER_ID = "4L6g3nShT-eMCtK--X86sw"; -const STARTER_SCRIPT = "/testcontainers_start.sh"; +const STARTER_SCRIPT = "/tmp/testcontainers_start.sh"; const WAIT_FOR_SCRIPT_MESSAGE = "Waiting for script..."; // https://docs.confluent.io/platform/7.0.0/release-notes/index.html#ak-raft-kraft