Apache Kafka

Ficheiros e Diretórios Importantes

• Diretório principal de instalação do Kafka: /opt/kafka
• Arquivo de configuração do broker Kafka: /opt/kafka/config/server.properties
• Diretório de logs do Kafka (logs do broker, eventos retidos): /opt/kafka/logs
• Binários e ferramentas CLI do Kafka (kafka-topics.sh, kafka-console-producer.sh, etc.): /opt/kafka/bin
• Unidade de serviço systemd para gerenciar o Kafka: /etc/systemd/system/kafka.service

Serviço Kafka

sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka

Criar um Tópico

/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Verificar detalhes do tópico:

/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

Produzir Eventos (Mensagens)

/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

Digite um evento por linha.

Pressione Ctrl+C sair.

Consumir Eventos

/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

Pressione Ctrl+C parar de ler.

Os eventos podem ser consumidos múltiplas vezes por múltiplos clientes.

Logs e Solução de Problemas

• Logs do Kafka: /opt/kafka/logs
• Diário do Systemd: sudo journalctl -u kafka -f
• Garantir portas 9092 (corretora) e 9093 (controller) estão abertos.