Apache Kafka

File e directory importanti

• Directory di installazione principale di Kafka: /opt/kafka
• File di configurazione del broker Kafka: /opt/kafka/config/server.properties
• Directory dei log di Kafka (registri del broker, eventi conservati): /opt/kafka/logs
• Binari Kafka e strumenti CLI (kafka-topics.sh, kafka-console-producer.sh, ecc.): /opt/kafka/bin
• Unità di servizio Systemd per la gestione di Kafka: /etc/systemd/system/kafka.service

Servizio Kafka

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

Crea un argomento

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

Controlla i dettagli dell'argomento:

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

Produrre eventi (messaggi)

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

Digita un evento per riga.

Premere Ctrl+C per uscire.

Consumare eventi

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

Premere Ctrl+C per smettere di leggere.

Gli eventi possono essere utilizzati più volte da più client.

Registri e risoluzione dei problemi

• Registri di Kafka: /opt/kafka/logs
• Diario di sistema: sudo journalctl -u kafka -f
• Garantire i porti 9092 (intermediario) e 9093 (controller) sono aperti.