Amazon MSK — Kafka Event Bus
CloudEvents v1.0 | Avro Schema Registry | Exactly-once semantics
byld-identity
Client onboarding, KYC, profile management
Produces: 6 events
byld-advisory
Risk profiling, goal planning, recommendations
Produces: 5 events
byld-portfolio
Holdings, transactions, NAV sync, XIRR
Produces: 5 | Consumes: 4
byld-mia
AI chatbot, NLP, action execution
Produces: 3 | Consumes: 6
byld-distribution
MF orders, SIP, SWP via MFU
Produces: 5 events
byld-markets
Market data, quotes, watchlists, alerts
Produces: 4 events
byld-payments
UPI, mandate, settlement, reconciliation
Produces: 3 | Consumes: 4
byld-notification
Push, SMS, email, WhatsApp, in-app
Consumes: 18 events
byld-estate
eWills, insurance, nominee, Willjini
Consumes: 3 events
Event Catalog
38 domain events | CloudEvents v1.0 envelope | Avro schemas
Domain Events — 24 events
ClientOnboarded
byld.identity.events
mia, portfolio, notification
KycCompleted
byld.identity.events
advisory, distribution
TierUpgraded
byld.identity.events
mia, notification, advisory
RiskProfileAssessed
byld.advisory.events
portfolio, mia, notification
GoalCreated
byld.advisory.events
portfolio, mia, notification
RebalanceRecommended
byld.advisory.events
portfolio, mia, notification
HoldingAdded
byld.portfolio.events
mia, advisory, notification
TransactionRecorded
byld.portfolio.events
advisory, notification
PortfolioRebalanced
byld.portfolio.events
mia, notification
AADataImported
byld.portfolio.events
advisory, mia, notification
NAVUpdated
byld.portfolio.events
mia, markets
OrderPlaced
byld.distribution.events
payments, portfolio, notification
OrderExecuted
byld.distribution.events
portfolio, notification
SIPRegistered
byld.distribution.events
payments, notification
MiaInteractionLogged
byld.mia.events
advisory
ActionExecuted
byld.mia.events
notification
PaymentSettled
byld.payments.events
distribution, portfolio, notification
MarketAlertTriggered
byld.markets.events
mia, notification
PriceTargetHit
byld.markets.events
mia, notification
Commands — 8 commands
InitiateKyc
byld.identity.commands
identity
PlaceMFOrder
byld.distribution.commands
distribution
ProcessPayment
byld.payments.commands
payments
SyncNAVs
byld.portfolio.commands
portfolio
SendNotification
byld.notification.commands
notification
Compensation Events — 6 events
OrderRolledBack
byld.distribution.compensation
payments, notification
PaymentRefunded
byld.payments.compensation
distribution, notification
KycVerificationFailed
byld.identity.compensation
notification
MandateCancelled
byld.payments.compensation
distribution, notification
AAConsentRevoked
byld.portfolio.compensation
portfolio, notification
CloudEvents v1.0 Envelope
{
"specversion": "1.0",
"type": "com.byld.portfolio.HoldingAdded",
"source": "byld-portfolio/v1",
"subject": "byld.portfolio.events",
"id": "f47ac10b-58cc-4372-a567...",
"time": "2026-03-17T10:30:00Z",
"datacontenttype": "application/avro",
"data": { ...schema-validated payload... }
}
"specversion": "1.0",
"type": "com.byld.portfolio.HoldingAdded",
"source": "byld-portfolio/v1",
"subject": "byld.portfolio.events",
"id": "f47ac10b-58cc-4372-a567...",
"time": "2026-03-17T10:30:00Z",
"datacontenttype": "application/avro",
"data": { ...schema-validated payload... }
}