Apache Kafka

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) y 9093 (controlador) estén abiertos.