create-user.sh

#!/bin/bash

echo "[Kafka Installer] install openjdk-8"
sudo apt-get install openjdk-8-jdk
echo "[Kafka Installer] java version printing test"
java -version
javac -version

sudo useradd kafka -m
sudo passwd kafka
sudo adduser kafka sudo
su -l kafka

ubuntu-kafka-install.sh

#!/bin/bash
mkdir ~/Downloads


echo "[Kafka Installer] download kafka-2.2.1 binary "
curl "http://mirror.navercorp.com/apache/kafka/2.2.1/kafka_2.12-2.2.1.tgz" -o ~/Downloads/kafka.tgz
mkdir ~/kafka && cd ~/kafka

echo "[Kafka Installer] extract.. "
tar -xvzf ~/Downloads/kafka.tgz --strip 1

echo "[Kafka Installer] delete topic option enable "
echo -e "\n delete.topic.enable = true" >> ~/kafka/config/server.properties

# Jookeeper
echo "[Kafka Installer] Jookeeper service regist"

echo "[Unit]" >> /etc/systemd/system/zookeeper.service 
echo "Requires=network.target remote-fs.target" >> /etc/systemd/system/zookeeper.service
echo "After=network.target remote-fs.target" >> /etc/systemd/system/zookeeper.service

echo "[Service]" >> /etc/systemd/system/zookeeper.service
echo "Type=simple" >> /etc/systemd/system/zookeeper.service
echo "User=kafka" >> /etc/systemd/system/zookeeper.service
echo "ExecStart=/home/kafka/kafka/bin/zookeeper-server-start.sh /home/kafka/kafka/config/zookeeper.properties" >> /etc/systemd/system/zookeeper.service
echo "ExecStop=/home/kafka/kafka/bin/zookeeper-server-stop.sh" >> /etc/systemd/system/zookeeper.service
echo "Restart=on-abnormal" >> /etc/systemd/system/zookeeper.service

echo "[Install]"
echo "WantedBy=multi-user.target"

# Kafka
echo "[Kafka Installer] Kafka service regist"
echo "[Unit]" >> /etc/systemd/system/kafka.service
echo "Requires=zookeeper.service" >> /etc/systemd/system/kafka.service
echo "After=zookeeper.service" >> /etc/systemd/system/kafka.service

echo "[Service]" >> /etc/systemd/system/kafka.service
echo "Type=simple" >> /etc/systemd/system/kafka.service
echo "User=kafka" >> /etc/systemd/system/kafka.service
echo "ExecStart=/bin/sh -c '/home/kafka/kafka/bin/kafka-server-start.sh /home/kafka/kafka/config/server.properties > /home/kafka/kafka/kafka.log 2>&1'" >> /etc/systemd/system/kafka.service
echo "ExecStop=/home/kafka/kafka/bin/kafka-server-stop.sh" >> /etc/systemd/system/kafka.service
echo "Restart=on-abnormal" >> /etc/systemd/system/kafka.service

echo "[Install]" >> /etc/systemd/system/kafka.service
echo "WantedBy=multi-user.target" >> /etc/systemd/system/kafka.service

echo "[Kafka Installer] Kafka service start"
sudo systemctl start kafka
sudo journalctl -u kafka
sudo systemctl enable kafka

echo "[Kafka Installer] Kafka topic test"
~/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic TutorialTopic
echo "Hello, World" | ~/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic TutorialTopic > /dev/null
~/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic TutorialTopic --from-beginning