Archivos y directorios importantes
- Directorio principal de instalación de Kafka:
/opt/kafka - Archivo de configuración del broker de Kafka:
/opt/kafka/config/server.properties - Directorio de logs de Kafka (logs del broker, eventos retenidos):
/opt/kafka/logs - Binarios de Kafka y herramientas CLI (
kafka-topics.sh,kafka-console-producer.sh, etc.):/opt/kafka/bin - Unidad de servicio systemd para gestionar Kafka:
/etc/systemd/system/kafka.service
Servicio de Kafka
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
Crear un topic
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Ver los detalles del topic:
/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
Producir eventos (mensajes)
/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
Escribe un evento por línea.
Pulsa Ctrl+C para salir.
Consumir eventos
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
Pulsa Ctrl+C para dejar de leer.
Múltiples clientes pueden consumir los eventos tantas veces como quieran.
Registros y solución de problemas
- Registros de Kafka:
/opt/kafka/logs - Journal de systemd:
sudo journalctl -u kafka -f - Asegúrate de que los puertos
9092(broker) y9093(controlador) estén abiertos.