Skip to content

Commit 0deaccb

Browse files
Revert "Wait for ZK to be listening when using provided ZK (#1039)"
This reverts commit adf3cda.
1 parent adf3cda commit 0deaccb

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

packages/modules/kafka/src/kafka-container.ts

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -300,17 +300,10 @@ export class KafkaContainer extends GenericContainer {
300300
}
301301

302302
private commandZookeeper(): string {
303-
const port = DEFAULT_ZOOKEEPER_PORT;
304-
305-
let command = `echo 'clientPort=${DEFAULT_ZOOKEEPER_PORT}' > zookeeper.properties\n`;
303+
let command = "echo 'clientPort=" + DEFAULT_ZOOKEEPER_PORT + "' > zookeeper.properties\n";
306304
command += "echo 'dataDir=/var/lib/zookeeper/data' >> zookeeper.properties\n";
307305
command += "echo 'dataLogDir=/var/lib/zookeeper/log' >> zookeeper.properties\n";
308306
command += "zookeeper-server-start zookeeper.properties &\n";
309-
310-
command += `echo "Waiting for ZooKeeper to be ready on port ${port}..."\n`;
311-
command += `while ! (echo > /dev/tcp/localhost/${port}) &> /dev/null; do sleep 0.1; done\n`;
312-
command += `echo "ZooKeeper is ready."\n`;
313-
314307
return command;
315308
}
316309
}

0 commit comments

Comments
 (0)