Archivos y directorios importantes
- Directorio principal de instalación de Kafka:
/opt/kafka - Archivo de configuración del agente Kafka:
/opt/kafka/config/server.properties - Directorio de registros de Kafka (registros de intermediarios, 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 Kafka
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
Crear un tema
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Verifique los detalles del tema:
/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
Escriba un evento por línea.
Prensa Ctrl+C para salir.
Consumir eventos
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
Prensa Ctrl+C para dejar de leer.
Los eventos pueden ser consumidos varias veces por varios clientes.
Registros y solución de problemas
- Registros de Kafka:
/opt/kafka/logs - Diario del sistema:
sudo journalctl -u kafka -f - Asegurar puertos
9092(corredor) y9093(controlador) están abiertos.
