Kafka Events
CRM Service produces 18 topics and consumes ~30 topics via Amazon MSK Serverless. All messages use CloudEvents 1.0 envelope format with tenantId as partition key.
Event Format
All events follow CloudEvents 1.0 specification with
specversion, type, source, id, time, and data fields.Produced Topics (18)
| Topic | Events |
|---|---|
| eventzr.crm.contact.v1 | created, updated, deleted, merged, enriched, tags_updated |
| eventzr.crm.account.created.v1 | Account created |
| eventzr.crm.account.updated.v1 | Account updated |
| eventzr.crm.account.deleted.v1 | Account deleted |
| eventzr.crm.deal.v1 | created, updated, deleted, stage_moved, won, lost |
| eventzr.crm.activity.v1 | created, updated, deleted |
| eventzr.crm.list.v1 | created, updated, deleted, members_added, members_removed, refreshed |
| eventzr.crm.pipeline.v1 | created, updated, deleted, stage_created, stages_reordered |
| eventzr.crm.campaign.started.v1 | Campaign started |
| eventzr.crm.campaign.completed.v1 | Campaign completed |
| eventzr.crm.campaign.failed.v1 | Campaign failed |
| eventzr.crm.connector.v1 | created, updated, deleted |
| eventzr.crm.import.started.v1 | Import started |
| eventzr.crm.import.completed.v1 | Import completed |
| eventzr.crm.import.failed.v1 | Import failed |
| eventzr.crm.staff.v1 | incentive_recorded |
| eventzr.ai.requests.v1 | AI enrichment/scoring requests |
| eventzr.kg.v1 | Knowledge graph projection |
Consumed Topics (sample of 14)
| Topic | Source Service |
|---|---|
| eventzr.aibrain.scoring.completed.v1 | aibrain-svc |
| eventzr.aibrain.enrichment.completed.v1 | aibrain-svc |
| eventzr.event.registration.created.v1 | event-svc |
| eventzr.event.attendance.recorded.v1 | event-svc |
| eventzr.subscriptions.subscription.created.v1 | subscriptions-svc |
| eventzr.notify.email.delivered.v1 | notify-svc |
| eventzr.notify.email.opened.v1 | notify-svc |
| eventzr.notify.email.clicked.v1 | notify-svc |
| eventzr.notify.email.bounced.v1 | notify-svc |
| eventzr.booking.booking.created.v1 | booking-svc |
| eventzr.wallet.payment.completed.v1 | wallet-svc |
| eventzr.taxonomy.tag.updated.v1 | taxonomy-svc |
| eventzr.sphere.user.updated.v1 | sphere-svc |
| eventzr.integrationhub.webhook.received.v1 | integration-hub-svc |
Full topic specification: see the downloadable asyncapi.yml on the Downloads page.