File e directory importanti
- Directory principale di installazione di Kafka:
/opt/kafka - File di configurazione del broker Kafka:
/opt/kafka/config/server.properties - Directory dei log di Kafka (log del broker, eventi conservati):
/opt/kafka/logs - Binari di 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 del topic:
/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
Scrivi un evento per riga.
Premi Ctrl+C per uscire.
Consuma Eventi
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
Premi Ctrl+C smettere di leggere.
Gli eventi possono essere consumati più volte da più client.
Registri e risoluzione dei problemi
- Log Kafka:
/opt/kafka/logs - Giornale systemd:
sudo journalctl -u kafka -f - Assicura porte
9092(broker) e9093(controller) sono aperti.
