diff options
| author |   seanfos <sean.osullivan@est.tech> | 2021-07-06 16:44:29 +0100 |
|---|---|---|
| committer | seanfos <sean.osullivan@est.tech> | 2021-07-13 14:51:03 +0100 |
| commit | 6345f40c1f562d5422ee45eca363a882e5c49456 (patch) | |
| tree | 2e101d0130a2e39e084b2db81f3886488e65de55 /src/main/docker/create-topics.sh | |
| parent | 106cb39ee18742829725b54262ddccc8feae2d71 (diff) | |
[DMAAP-KAFKA] Kafka Upgrade
Signed-off-by: seanfos <sean.osullivan@est.tech>
Change-Id: Ic83906004ca15494187972c9d8fd6a437766de85
Issue-ID: DMAAP-209
Diffstat (limited to 'src/main/docker/create-topics.sh')
| -rw-r--r-- | src/main/docker/create-topics.sh | 36 |
1 files changed, 0 insertions, 36 deletions
diff --git a/src/main/docker/create-topics.sh b/src/main/docker/create-topics.sh deleted file mode 100644 index 34945b3..0000000 --- a/src/main/docker/create-topics.sh +++ /dev/null @@ -1,36 +0,0 @@ -#!/bin/bash - - -if [[ -z "$START_TIMEOUT" ]]; then - START_TIMEOUT=600 -fi - -start_timeout_exceeded=false -count=0 -step=10 -while netstat -lnt | awk '$4 ~ /:'$KAFKA_PORT'$/ {exit 1}'; do - echo "waiting for kafka to be ready" - sleep $step; - count=$(expr $count + $step) - if [ $count -gt $START_TIMEOUT ]; then - start_timeout_exceeded=true - break - fi -done - -if $start_timeout_exceeded; then - echo "Not able to auto-create topic (waited for $START_TIMEOUT sec)" - exit 1 -fi - -if [[ -n $KAFKA_CREATE_TOPICS ]]; then - IFS=','; for topicToCreate in $KAFKA_CREATE_TOPICS; do - echo "creating topics: $topicToCreate" - IFS=':' read -a topicConfig <<< "$topicToCreate" - if [ ${topicConfig[3]} ]; then - JMX_PORT='' $KAFKA_HOME/bin/kafka-topics.sh --create --zookeeper $KAFKA_ZOOKEEPER_CONNECT --replication-factor ${topicConfig[2]} --partitions ${topicConfig[1]} --topic "${topicConfig[0]}" --config cleanup.policy="${topicConfig[3]}" --if-not-exists - else - JMX_PORT='' $KAFKA_HOME/bin/kafka-topics.sh --create --zookeeper $KAFKA_ZOOKEEPER_CONNECT --replication-factor ${topicConfig[2]} --partitions ${topicConfig[1]} --topic "${topicConfig[0]}" --if-not-exists - fi - done -fi |