-
sudo apt-get update
-
sudo apt-get install openjdk-8-jdk
-
sudo apt-get install zookeeperd
-
sudo systemctl status zookeeper
-
sudo systemctl start zookeeper
-
sudo systemctl enable zookeeper
sudo apt-get install net-tools
sudo netstat -tulpen | grep 2181
mkdir Downloads
cd Downloads
wget https://dlcdn.apache.org/kafka/3.1.0/kafka_2.12-3.1.0.tgz
sudo mkdir /opt/kafka
wget https://dlcdn.apache.org/kafka/3.1.0/kafka_2.12-3.1.0.tgz
sudo mkdir /opt/kafka
sudo tar xvzf kafka_2.12-3.1.0.tgz -C /opt/kafka
sudo nano /etc/profile
export KAFKA_HOME="/opt/kafka/kafka_2.12-3.1.0"
export PATH="$PATH:${KAFKA_HOME}/bin"
tail /etc/profile
sudo nano ~/.bashrc
alias sudo='sudo env PATH="$PATH"'
sudo reboot
echo $KAFKA_HOME echo $HOME
sudo ln -s $KAFKA_HOME/config/server.properties /etc/kafka.properties
sudo kafka-server-start.sh /etc/kafka.properties
kafka-topics.sh --create --topic qqb-topic --bootstrap-server localhost:9092
-> Producer: kafka-console-producer.sh --topic qqb-topic --bootstrap-server localhost:9092
-> Consumer:
kafka-console-consumer.sh --topic qqb-topic --from-beginning --bootstrap-server localhost:9092