Каталог топиков Kafka и схем событий, публикуемых сервисами AIOps.
identity.user.events
Producer: Identity service Назначение: жизненный цикл пользователя (canonical identity).
| Event Type | Описание | Ключ | Payload (основные поля) |
|---|---|---|---|
| USER_CREATED | Создан новый пользователь | user_id | id, username, status, created_at |
| USER_DISABLED | Пользователь деактивирован | user_id | id, username, disabled_at |
| USER_ENABLED | Пользователь активирован | user_id | id, username, enabled_at |
| USER_DELETED | Пользователь удален | user_id | id, username, deleted_at |
Consumers (planned): Account service (синхронизация username и удаление профиля).
identity.identifier.events
Producer: Identity service Назначение: привязка и верификация идентификаторов (email, phone).
| Event Type | Описание | Ключ | Payload (основные поля) |
|---|---|---|---|
| IDENTIFIER_ADDED | Идентификатор привязан к пользователю | user_id | user_id, identifier, type, verified |
| IDENTIFIER_VERIFIED | Идентификатор верифицирован | user_id | user_id, identifier, verified_at |
| IDENTIFIER_REMOVED | Идентификатор отвязан | user_id | user_id, identifier, removed_at |
Consumers (planned): Herald (отправка кодов верификации и уведомлений).
credential.password.events
Producer: Credential service Назначение: установка, смена и проверка пароля.
| Event Type | Описание | Ключ | Payload (основные поля) |
|---|---|---|---|
| PASSWORD_SET | Пароль установлен (регистрация) | user_id | user_id, must_change, created_at |
| PASSWORD_CHANGED | Пароль изменен пользователем | user_id | user_id, changed_at |
| PASSWORD_VERIFIED | Успешная проверка пароля (логин) | user_id | user_id, verified_at |
| PASSWORD_VERIFICATION_FAILED | Неудачная проверка (для аудита/мониторинга) | user_id | user_id, failed_at, attempts_count |
Consumers (planned): Account service (обновление метаданных), мониторинг безопасности.
Общие правила
- Ключ сообщения — идентификатор агрегата (user_id и т.д.) для партиционирования и идемпотентности потребителей.
- Тело — JSON с полями:
event_type,version,occurred_at,payload. - Версионирование: при несовместимых изменениях — новая версия поля или новый топик/суффикс.
- Идемпотентность: потребители должны учитывать повторную доставку (дедупликация по event_id или по ключу + условию).
Связанные страницы
- Event Flow — архитектура потока событий
- Event-Driven Patterns — Transactional Outbox
- Identity service — producer identity.*
- Credential service — producer credential.*