Skip to content

Instantly share code, notes, and snippets.

@iandow
Last active January 1, 2017 22:10

Revisions

  1. iandow revised this gist Jan 1, 2017. 1 changed file with 15 additions and 1 deletion.
    16 changes: 15 additions & 1 deletion watch_zookeeper.sh
    Original file line number Diff line number Diff line change
    @@ -1,7 +1,21 @@
    while true; do
    tail -n 40 /opt/kafka_2.11-0.10.0.1/logs/server.log | grep ZkTimeout;
    if [ $? -eq 0 ]; then
    ~/cleanup.sh;
    sudo service kafka stop
    ssh kafkanodeb sudo service kafka stop
    ssh kafkanodec sudo service kafka stop
    sudo rm -rf /tmp/kafka-logs
    ssh kafkanodeb sudo rm -rf /tmp/kafka-logs
    ssh kafkanodec sudo rm -rf /tmp/kafka-logs
    sudo rm -rf /tmp/zookeeper/version-2
    ssh kafkanodeb sudo rm -rf /tmp/zookeeper/version-2
    ssh kafkanodec sudo rm -rf /tmp/zookeeper/version-2
    ssh kafkanodeb sudo service kafka start
    ssh kafkanodec sudo service kafka start
    sudo service kafka start
    ssh kafkanodeb sudo service kafka status
    ssh kafkanodec sudo service kafka status
    sudo service kafka status
    fi;
    sleep 60;
    done
  2. iandow revised this gist Jan 1, 2017. 1 changed file with 7 additions and 1 deletion.
    8 changes: 7 additions & 1 deletion watch_zookeeper.sh
    Original file line number Diff line number Diff line change
    @@ -1 +1,7 @@
    while true; do tail -n 40 /opt/kafka_2.11-0.10.0.1/logs/server.log | grep ZkTimeout; if [ $? -eq 0 ]; then ~/cleanup.sh; fi; sleep 60; done
    while true; do
    tail -n 40 /opt/kafka_2.11-0.10.0.1/logs/server.log | grep ZkTimeout;
    if [ $? -eq 0 ]; then
    ~/cleanup.sh;
    fi;
    sleep 60;
    done
  3. iandow created this gist Jan 1, 2017.
    1 change: 1 addition & 0 deletions watch_zookeeper.sh
    Original file line number Diff line number Diff line change
    @@ -0,0 +1 @@
    while true; do tail -n 40 /opt/kafka_2.11-0.10.0.1/logs/server.log | grep ZkTimeout; if [ $? -eq 0 ]; then ~/cleanup.sh; fi; sleep 60; done