~x3v947pl/charms/trusty/kafka-dh/trunk

« back to all changes in this revision

Viewing changes to hooks/zk-relation-changed

  • Committer: devicehive
  • Date: 2015-09-01 18:30:57 UTC
  • Revision ID: admin@devicehive.com-20150901183057-eateyl36r34ifyf6
initial commit

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
#!/bin/bash
 
2
 
 
3
set -ux
 
4
 
 
5
ZK_PUB_ADDR=`relation-get ZK_PUB_ADDR`
 
6
ZK_PRIV_ADDR=`relation-get ZK_PRIV_ADDR`; if [ -z "$ZK_PRIV_ADDR" ]; then exit; fi
 
7
 
 
8
if [ ! -z "`echo $ZK_PUB_ADDR|grep "[a-zA-Z]"`" ]; then ZK_PUB_ADDR=`host $ZK_PUB_ADDR|grep "has address"|head -n 1|sed 's/^.*\ //'`; fi
 
9
if [ -z "$ZK_PUB_ADDR" ]; then
 
10
    ZK_HOST=$ZK_PRIV_ADDR
 
11
else
 
12
    ZK_HOST=$ZK_PUB_ADDR
 
13
fi
 
14
 
 
15
if [ ! -z "`grep "\<$ZK_HOST:2181\>" /opt/kafka/config/server.properties`" ]; then exit; fi
 
16
 
 
17
#alter config
 
18
zookeeper_list=`grep "zookeeper.connect=" /opt/kafka/config/server.properties|sed 's/zookeeper.connect=//'`
 
19
if [ -z "$zookeeper_list" ]; then
 
20
    sed -i "s/^\(zookeeper.connect=\)/\1$ZK_HOST:2181/" /opt/kafka/config/server.properties
 
21
else
 
22
    sed -i "s/^\(zookeeper.connect=\).*/\1$zookeeper_list,$ZK_HOST:2181/" /opt/kafka/config/server.properties
 
23
fi
 
24
 
 
25
echo "$JUJU_REMOTE_UNIT-$JUJU_RELATION_ID $ZK_HOST" >> $CHARM_DIR/files/zkserverlist
 
26
 
 
27
$CHARM_DIR/hooks/start