Logo Event-Driven Architecture Live

MCP + Lightspeed

OpenShift Lightspeed con MCP

OpenShift Lightspeed es un asistente de IA integrado en la consola de OpenShift que tiene acceso a herramientas MCP (Model Context Protocol) para diagnosticar y resolver problemas en el cluster.

En este cluster, Lightspeed tiene acceso a 55+ herramientas MCP que cubren Kubernetes, OpenShift, ArgoCD, Developer Hub, y ahora también el pipeline de Kafka/CDC.

Prompts de troubleshooting para el CDC Pipeline

Kafka Cluster

Situación Prompt para Lightspeed

Cluster Kafka no está listo

"Get the Kafka resource in namespace kafka-cdc and show its status"

Brokers no arrancan

"Get pods in namespace kafka-cdc with label strimzi.io/kind=Kafka and show their status"

Topics no se crean

"List KafkaTopics in namespace kafka-cdc"

Debezium / KafkaConnect

Situación Prompt para Lightspeed

KafkaConnect build fallando

"Get the logs from the KafkaConnect pod in namespace kafka-cdc"

Debezium no captura cambios

"Get the KafkaConnectors in namespace kafka-cdc and show their status"

Connector en estado FAILED

"Get events in namespace kafka-cdc related to KafkaConnect"

Replication slot no se crea

"Get the logs from deployment cdc-postgresql in namespace kafka-cdc"

Kafka Bridge

Situación Prompt para Lightspeed

Bridge no responde

"Get pods in namespace kafka-cdc with label strimzi.io/kind=KafkaBridge"

Error al producir via REST

"Get the logs from the KafkaBridge pod in namespace kafka-cdc"

Apicurio Registry

Situación Prompt para Lightspeed

Registry no disponible

"Get pods in namespace kafka-cdc with label app=apicurio-registry"

Error de conexión a Kafka

"Get the logs from the ApicurioRegistry pod in namespace kafka-cdc"

Camel CDC Processor

Situación Prompt para Lightspeed

Procesador no arranca

"Get pods in namespace kafka-cdc with label app=camel-cdc-processor"

Errores en la ruta Camel

"Get the logs from deployment camel-cdc-processor in namespace kafka-cdc"

Emails no llegan a Mailpit

"Check connectivity from namespace kafka-cdc to n8n-mailpit.openshift-lightspeed.svc"

Streams Console

Situación Prompt para Lightspeed

Consola no carga

"Get the Console resource in namespace kafka-cdc and show its status"

Error de autenticación

"Get events in namespace kafka-cdc related to Console"

How it Works

Model Context Protocol (MCP)

MCP es un protocolo abierto que conecta modelos de IA con herramientas externas:

  1. Lightspeed recibe el prompt del usuario en la consola de OpenShift.

  2. El modelo analiza la intención y selecciona las herramientas MCP relevantes de las 55+ disponibles.

  3. Para cada herramienta seleccionada, MCP ejecuta una function call contra el API server de OpenShift (o ArgoCD, etc.) con los parámetros inferidos del prompt.

  4. Los resultados (YAML de recursos, logs, eventos) se inyectan de vuelta en el contexto del modelo.

  5. El modelo sintetiza una respuesta que combina la información obtenida con su conocimiento sobre la plataforma.

Flujo de un prompt de troubleshooting

Cuando un usuario pregunta "Get the KafkaConnectors in namespace kafka-cdc and show their status":

  1. Lightspeed identifica que necesita la herramienta k8s_listResources con kind: KafkaConnector, namespace: kafka-cdc.

  2. MCP ejecuta el equivalente de oc get kafkaconnectors -n kafka-cdc -o json.

  3. El JSON de respuesta contiene los CRs con sus .status.conditions (tipo, estado, mensaje).

  4. El modelo interpreta las conditions y produce una respuesta legible: "El connector debezium-postgresql-source está en estado RUNNING con 1 task activa. El connector mailpit-http-sink está RUNNING con 1 task."

  5. Si detecta un estado anormal (FAILED, PAUSED), sugiere acciones correctivas basadas en los mensajes de error.

Seguridad y permisos

Las herramientas MCP se ejecutan con los permisos del ServiceAccount configurado en el namespace mcp-system. El RBAC de OpenShift controla qué recursos puede leer o modificar — Lightspeed no tiene acceso irrestricto al cluster.

Workflow de diagnóstico rápido

Para validar todo el pipeline CDC después de un deployment, ejecuta estos prompts en secuencia:

1. "Get the Kafka resource in namespace kafka-cdc and check if it's ready"
2. "Get KafkaConnectors in namespace kafka-cdc and show their status"
3. "Get pods in namespace kafka-cdc and check their status"
4. "Check if consumer group camel-cdc-consumer has lag in namespace kafka-cdc"
5. "Get the Console resource in namespace kafka-cdc"
6. "Get the ApicurioRegistry resource in namespace kafka-cdc"

MCP Tools disponibles para Kafka

Las herramientas MCP registradas en mcp-system que son relevantes para el pipeline CDC:

Tool Uso

k8s_listPods

Listar pods del namespace kafka-cdc

k8s_getPodLogs

Ver logs de cualquier componente del pipeline

k8s_listEvents

Ver eventos del namespace para troubleshooting

ocp_getRoute

Verificar acceso a Kafka Console, Bridge, Apicurio

argo_listApplications

Ver estado de las ArgoCD Applications de Kafka/CDC

Documentación Oficial