CryptoJones

Kafka-ZooKeeper-Setup.sh

Oct 19th, 2022 (edited)
1,876
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Bash 2.96 KB | None | 0 0
  1. ```bash
  2.  
  3. ''' ZooKeeper '''
  4.  
  5. adduser zookeeper --shell=/bin/false --no-create-home --system --group
  6.  
  7. apt-get install openjdk-17-jdk -y
  8.  
  9. cd /opt
  10.  
  11. wget https://archive.apache.org/dist/zookeeper/zookeeper-3.7.1/apache-zookeeper-3.7.1-bin.tar.gz
  12.  
  13. tar -zxf apache-zookeeper-3.7.1-bin.tar.gz
  14.  
  15. ln -s /opt/apache-zookeeper-3.7.1-bin /opt/zookeeper
  16.  
  17. cd /opt/zookeeper
  18.  
  19. mkdir -p /var/zookeeper/data
  20.  
  21. nano /opt/zookeeper/conf/zoo.cfg
  22.  
  23.  
  24. # replace 1 (server.1) below with your node number
  25.  
  26. --------------------------------
  27.  
  28. tickTime = 2000
  29. dataDir = /var/zookeeper/data
  30. clientPort = 2181
  31. initLimit = 5
  32. syncLimit = 2
  33. maxClientCnxns=60
  34. autopurge.purgeInterval=1
  35. admin.enableServer=false
  36. 4lw.commands.whitelist=*
  37. server.1=127.0.0.1:2888:3888
  38. admin.enableServer=false
  39.  
  40. --------------------------------
  41.  
  42. # replace 1 below with your node number
  43.  
  44. bash -c 'echo 1 > /var/zookeeper/data/myid'
  45.  
  46. ./bin/zkServer.sh start
  47.  
  48. ./bin/zkCli.sh
  49.  
  50. ./bin/zkServer.sh stop
  51.  
  52. chown -R zookeeper:zookeeper /opt/apache-zookeeper-3.7.1-bin
  53.  
  54. chown -R zookeeper:zookeeper /var/zookeeper/data
  55.  
  56.  
  57. nano /etc/systemd/system/zookeeper.service
  58.  
  59. ---------------------------------
  60. [Unit]
  61. Description=Zookeeper Daemon
  62. Documentation=http://zookeeper.apache.org
  63. Requires=network.target
  64. After=network.target
  65.  
  66. [Service]
  67. Type=forking
  68. WorkingDirectory=/opt/zookeeper
  69. User=zookeeper
  70. Group=zookeeper
  71. ExecStart=/opt/zookeeper/bin/zkServer.sh start /opt/zookeeper/conf/zoo.cfg
  72. ExecStop=/opt/zookeeper/bin/zkServer.sh stop /opt/zookeeper/conf/zoo.cfg
  73. ExecReload=/opt/zookeeper/bin/zkServer.sh restart /opt/zookeeper/conf/zoo.cfg
  74. TimeoutSec=30
  75. Restart=on-failure
  76.  
  77. [Install]
  78. WantedBy=default.target
  79. ---------------------------------
  80.  
  81. systemctl start zookeeper
  82.  
  83. systemctl status zookeeper
  84.  
  85. systemctl enable zookeeper
  86.  
  87.  
  88.  
  89.  
  90. ''' Kafka '''
  91. adduser kafka --shell=/bin/false --no-create-home --system --group
  92.  
  93. cd /opt
  94.  
  95. wget https://dlcdn.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz
  96.  
  97. tar -zxf kafka_2.13-3.3.1.tgz
  98.  
  99. rm kafka_2.13-3.3.1.tgz
  100.  
  101. mkdir /var/log/kafka
  102.  
  103. mkdir /var/kafka-data
  104.  
  105. chown kafka:kafka /var/log/kafka
  106.  
  107. chown kafka:kafka /var/kafka-data
  108.  
  109. ln -s /opt/kafka_2.13-3.3.1 /opt/kafka
  110.  
  111. cd /opt/kafka
  112.  
  113. nano config/server.properties
  114.  
  115. # replace 1 below with your node number
  116.  
  117. -------------------------------
  118. broker.id=1
  119. log.dirs=/var/kafka-data
  120. delete.topic.enable = true
  121. -------------------------------
  122.  
  123. nano /etc/systemd/system/kafka.service
  124.  
  125. -------------------------------
  126.  
  127. [Unit]
  128. Requires=zookeeper.service
  129. After=zookeeper.service
  130.  
  131. [Service]
  132. Type=simple
  133. User=kafka
  134. LimitNOFILE=800000
  135. Environment="LOG_DIR=/var/log/kafka"
  136. Environment="GC_LOG_ENABLED=true"
  137. Environment="KAFKA_HEAP_OPTS=-Xms512M -Xmx4G"
  138. ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
  139. Restart=on-failure
  140.  
  141. [Install]
  142. WantedBy=multi-user.target
  143.  
  144. --------------------------------------
  145.  
  146. systemctl start kafka
  147.  
  148. systemctl status kafka
  149.  
  150. systemctl enable kafka
  151.  
Advertisement
Add Comment
Please, Sign In to add comment