StreamForge

# Descargar el paquete .deb
wget https://repo.streamforge.app/streamforge_0.10.0_amd64.deb

# Instalar
sudo dpkg -i streamforge_0.10.0_amd64.deb

# Iniciar el broker
sudo systemctl start streamforge
sudo systemctl enable streamforge

# Verificar status
sudo systemctl status streamforge

# Ver logs
sudo journalctl -u streamforge -f

# Verificar API
curl http://localhost:8080/api/health

# Crear usuario admin (primera vez)
sudo /usr/bin/streamforge-broker create-admin \
  --username admin \
  --password your-secure-password

# Login y obtener token JWT
curl -X POST http://localhost:8080/api/auth/login \
  -H "Content-Type: application/json" \
  -d '{
    "username": "admin",
    "password": "your-secure-password"
  }'

# Guardar el token
export TOKEN="eyJ0eXAiOiJKV1Qi..."

# Crear topic con 4 particiones
curl -X POST http://localhost:8080/api/topics \
  -H "Authorization: Bearer $TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "my-topic",
    "num_partitions": 4
  }'

# Publicar mensaje a un topic
curl -X POST http://localhost:8080/api/topics/my-topic/publish \
  -H "Authorization: Bearer $TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "payload": {
      "user_id": 123,
      "action": "login",
      "timestamp": "2025-11-08T10:30:00Z"
    }
  }'

# Leer los últimos 10 mensajes de un topic
curl "http://localhost:8080/api/topics/my-topic/messages?latest=true&limit=10" \
  -H "Authorization: Bearer $TOKEN"

# Response incluye partition_offsets para tracking:
{
  "topic": "my-topic",
  "messages": [
    {
      "partition": 0,
      "offset": 95,
      "key": null,
      "value": {"user_id": 123, "action": "login"},
      "timestamp": "2025-11-28T10:30:00Z"
    }
  ],
  "count": 1,
  "partition_offsets": [
    {"partition": 0, "oldest_offset": 0, "newest_offset": 100, "total_messages": 101}
  ]
}

# Leer desde offset específico
curl "http://localhost:8080/api/topics/my-topic/messages?offset=50&limit=20" \
  -H "Authorization: Bearer $TOKEN"