aboutsummaryrefslogtreecommitdiff
path: root/system/kafka/doinst.sh
blob: 0a3830be41aa71df590381cc18fe1d0bd2efd5b7 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
config() {
  NEW="$1"
  OLD="$(dirname $NEW)/$(basename $NEW .new)"
  if [ ! -r $OLD ]; then
    mv $NEW $OLD
  elif [ "$(cat $OLD | md5sum)" = "$(cat $NEW | md5sum)" ]; then
    rm $NEW
  fi
}

preserve_perms() {
  NEW="$1"
  OLD="$(dirname $NEW)/$(basename $NEW .new)"
  if [ -e $OLD ]; then
    cp -a $OLD ${NEW}.incoming
    cat $NEW > ${NEW}.incoming
    mv ${NEW}.incoming $NEW
  fi
  config $NEW
}

preserve_perms etc/rc.d/rc.kafka.new
preserve_perms etc/kafka/server.properties.new
preserve_perms etc/kafka/consumer.properties.new
preserve_perms etc/kafka/producer.properties.new
preserve_perms etc/kafka/log4j.properties.new
preserve_perms etc/kafka/test-log4j.properties.new
preserve_perms etc/kafka/tools-log4j.properties.new
preserve_perms etc/kafka/kafka-env.sh.new
preserve_perms etc/kafka/connect-console-sink.properties.new
preserve_perms etc/kafka/connect-console-source.properties.new
preserve_perms etc/kafka/connect-distributed.properties.new
preserve_perms etc/kafka/connect-file-sink.properties.new
preserve_perms etc/kafka/connect-file-source.properties.new
preserve_perms etc/kafka/connect-log4j.properties.new
preserve_perms etc/kafka/connect-standalone.properties.new