瀏覽代碼

Instead of sleeping, poll for the socket to be ready

Hopefully this fixes the heisenbug where we try to set up the topics before the
cluster has actually booted.
Evan Huus 10 年之前
父節點
當前提交
bfef474645
共有 1 個文件被更改,包括 2 次插入1 次删除
  1. 2 1
      vagrant/create_topics.sh

+ 2 - 1
vagrant/create_topics.sh

@@ -2,7 +2,8 @@
 
 
 set -ex
 set -ex
 
 
-sleep 10
+while ! nc -q 1 localhost 21801 </dev/null; do echo "Waiting"; sleep 1; done
+while ! nc -q 1 localhost 29092 </dev/null; do echo "Waiting"; sleep 1; done
 
 
 cd ${KAFKA_INSTALL_ROOT}/kafka-9092
 cd ${KAFKA_INSTALL_ROOT}/kafka-9092
 bin/kafka-topics.sh --create --partitions 1 --replication-factor 3 --topic single_partition --zookeeper localhost:2181
 bin/kafka-topics.sh --create --partitions 1 --replication-factor 3 --topic single_partition --zookeeper localhost:2181