ADR-0002. Activity notification do Kafka cấp, lưu trong core, rồi push

Bối cảnh

Sự kiện domain (vd thanh toán thành công) cần trở thành notification bền vững, theo từng user hiển thị trong UI "chuông" và một gợi ý WS live.
Producer biết điều gì xảy ra và một phạm vi người nhận (org / merchant / users rõ ràng) nhưng không biết danh sách người nhận cụ thể.
Signal đã sở hữu edge WebSocket nhưng không có schema; bảng ActivityNotification tập trung trong @nx/core.
Notification phải sống sót qua một socket lỡ — client có thể offline khi sự kiện bắn.

Chúng ta sẽ cấp activity notification cho Signal qua Kafka (signal.activity-notification), và để worker giải → lưu → push:

Consume TActivityNotificationMessage; từ chối eventType lạ.
Giải người nhận phía server — org/merchant qua PolicyDefinitionRepository, users qua recipientIds rõ ràng (fallback [actorId]).
Dựng content + html từ một markdown decorator, lưu một hàng ActivityNotification mỗi người nhận qua createAll.
Push observation/signal/notification/created tới mỗi room signal/notification/{recipientId}.

Consumer chạy với autocommit: false, commit theo từng message sau khi handler return, và fallbackMode: latest.

Ưu	Nhược
Notification bền vững (DB) và live (WS)	Re-delivery tạo hàng trùng — không dedup hôm nay
Producer giữ chỉ-scope; Signal sở hữu giải người nhận	Giải người nhận là một lần hit DB đồng bộ mỗi message
Tái dùng schema/repo tập trung `@nx/core`	Lỗi handler được log nhưng không retry/DLQ
Commit thủ công cho an toàn at-least-once	Hiện chỉ hiện thực nội dung `PAYMENT_SUCCESS`

Phương án	Ưu	Nhược	Vì sao loại
Chỉ push WS (không lưu)	Đơn giản nhất	Mất nếu client offline; không lịch sử	UI chuông cần lịch sử bền vững
Producer giải người nhận + ghi hàng	Signal giữ ngu	Mỗi producer lặp giải + kiến thức schema	Tập trung trong Signal DRY hơn
Autocommit + idempotency key	Ít code thủ công	Cần store dedup; chưa xây	Hoãn; commit thủ công là an toàn tạm