sudo su
criação usuario:
adduser belem
senha: root1@
adicionando usuario ao grupo sudo
usermod -aG sudo belem
Entrar no usuario
su - belem
sudo apt update
Instalação
sudo apt install openjdk-11-jre-headless -y
https://www.vultr.com/docs/install-apache-kafka-on-ubuntu-20-04
mkdir ~/Downloads
cd Downloads
mkdir ~/kafka
sudo mv kafka_2.13-2.8.2/ ~/kafka
cd ~/kafka
Dar permissão de escrita:
sudo chmod a+w server.properties
.
.
sudo nano ~/kafka/config/server.properties
Adicionar na ultima linha do arquivo server.properties
Dar permissão de escrita:
sudo nano /etc/systemd/system/kafka.service
Iniciar o Kafka:
sudo systemctl start kafka
Primeiro iniciar o Zookeeper depois o Kafka
Dar permissão de escrita:
sudo chmod a+w /etc/systemd/system/zookeeper.service
Alterar
sudo nano /etc/systemd/system/zookeeper.service
.
IMPORTANTE ESTAR NO USUARIO BELEM
https://www.confluent.io/blog/set-up-and-run-kafka-on-windows-linux-wsl-2/
cd kafka
Dar permissão de escrita
sudo chmod a+w zookeeper.properties
Alterar a porta do arquivo
sudo nano ~/kafka/config/zookeeper.properties
Alterar a porta de 2181 para 2182
Iniciar o zookeeper
sudo bin/zookeeper-server-start.sh config/zookeeper.properties
Abra outra sessão de terminal. Inicie o broker Kafka:
cd kafka
sudo bin/kafka-server-start.sh config/server.properties
Criação do tópico:
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Abrir outra janela, iniciar producer para enviar as mensagens
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
Abrir outra janela, iniciar consumer para receber as mensagens
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
dbc
, kafka
, zookeeper