Kafka no tiene interfaz web. La interacción es directamente desde producers/consumers usando el puerto del broker.

‍

Connection string

<IP_DE_LA_VM>:30909

‍

Verificar conectividad con kafka-topics

# Listar topics existentes
kafka-topics.sh --bootstrap-server <IP_DE_LA_VM>:30909 --list

# Crear un topic
kafka-topics.sh --bootstrap-server <IP_DE_LA_VM>:30909 \
  --create --topic mi-topic --partitions 3 --replication-factor 1

# Describir un topic
kafka-topics.sh --bootstrap-server <IP_DE_LA_VM>:30909 \
  --describe --topic mi-topic

‍

Ejemplo con producer y consumer

# Enviar mensajes (producer)
kafka-console-producer.sh --bootstrap-server <IP_DE_LA_VM>:30909 --topic mi-topic

# Recibir mensajes (consumer)
kafka-console-consumer.sh --bootstrap-server <IP_DE_LA_VM>:30909 \
  --topic mi-topic --from-beginning

‍

Connection string para aplicaciones

# Java / Spring Boot
bootstrap-servers=<IP_DE_LA_VM>:30909

# Python (kafka-python)
bootstrap_servers=['<IP_DE_LA_VM>:30909']

# Node.js (kafkajs)
brokers: ['<IP_DE_LA_VM>:30909']

# Ver el pod de Kafka
kubectl get pods -A | grep kafka

# Ver log de instalación
tail -f /var/log/cuemby/bootstrap.log

# Verificar que el puerto está escuchando
ss -tlnp | grep 30909

‍

Output esperado:

NAME                     READY   STATUS    RESTARTS
kafka-xxxxxxxxx-xxxxx    1/1     Running   0        ← Running ✓

‍

ℹ️ Esta instalación usa KRaft mode (sin ZooKeeper). No requiere un ensemble de ZooKeeper separado.

# 1. Crear un topic con 3 particiones
kafka-topics.sh --bootstrap-server <IP_DE_LA_VM>:30909 \
  --create --topic eventos --partitions 3 --replication-factor 1

# 2. Verificar que el topic fue creado
kafka-topics.sh --bootstrap-server <IP_DE_LA_VM>:30909 --list

# 3. Producir un mensaje de prueba
echo "hola mundo" | kafka-console-producer.sh \
  --bootstrap-server <IP_DE_LA_VM>:30909 --topic eventos

# 4. Consumir el mensaje
kafka-console-consumer.sh --bootstrap-server <IP_DE_LA_VM>:30909 \
  --topic eventos --from-beginning --max-messages 1

‍

💡 Tip: Ajusta KAFKA_HEAP_OPTS si ves errores de OutOfMemoryError. Con 8 GB de RAM, un valor como -Xmx3g -Xms3g da margen suficiente para workloads de producción ligeros.