OpenClaw Agent — Events (Kafka)
Kafka не используется в MVP
Все взаимодействия — синхронные HTTP-вызовы. SSE-стрим — между Agent и admin-bff/web, не через Kafka.
Возможные топики на будущее (Phase 2)
| Топик | Producer / Consumer | Назначение | Когда подключить |
|---|---|---|---|
agent.conversation.created | Agent → consumers TBD | Аналитика usage по франшизам | Когда подключим Report Service (BR 6.4) — для дашборда «AI usage» |
agent.tool.executed | Agent → audit service | Аудит-лог всех tool_call от агента | Если бизнес попросит compliance trail |
agent.error.raised | Agent → monitoring | Алерты на проседание агента | После 1-2 месяцев работы, когда поймём что мониторить |
Что отправляет / получает сервис вместо Kafka в MVP
| Тип | С кем | Канал |
|---|---|---|
| Входящие чат-сообщения | Admin BFF | HTTP REST (POST /chat) |
| Стрим ответов | Admin BFF → Admin Web | SSE через тот же /chat endpoint |
| Inference | LLM-провайдер (TBD — см. Overview) | HTTP REST с SSE |
| Tool execution | Catalog, Order | HTTP REST (юзеровский JWT) |
| Health | Service mesh | HTTP /internal/agent/health |