Kafka Events

15 event topics across 6 categories published to Amazon MSK Serverless.

Event Format: CloudEvents 1.0

All events follow the CloudEvents 1.0 specification and are published using the transactional outbox pattern. Events are partitioned by tenant_id and published to Amazon MSK Serverless via the OutboxPublisherService.

Brokers

Environment	Broker
Staging	`b-1.eventzr-msk.ap-south-1.amazonaws.com:9098`
Production	`b-1.eventzr-msk-prod.ap-south-1.amazonaws.com:9098`

Event Envelope

CloudEvents 1.0 envelopejson

{
  "specversion": "1.0",
  "type": "eventzr.review.created.v1",
  "source": "reviews-svc",
  "id": "evt-550e8400-e29b-41d4-a716-446655440000",
  "time": "2026-02-24T12:00:00.000Z",
  "datacontenttype": "application/json",
  "subject": "tenant-uuid",
  "data": {
    "reviewId": "rev_01HXYZ...",
    "tenantId": "00000000-0000-0000-0000-000000000001",
    "userId": "usr_abc123",
    "entityType": "event",
    "entityId": "evt_abc123xyz",
    "rating": 5,
    "title": "Amazing event!",
    "content": "This was one of the best events I have attended.",
    "sentiment": "positive",
    "sentimentScore": 0.92,
    "isVerifiedPurchase": true,
    "isAnonymous": false,
    "status": "published",
    "tags": ["well-organized", "great-speakers"],
    "createdAt": "2026-02-24T12:00:00.000Z"
  }
}

Event Topics (15)

Review Lifecycle4

Topic	Description
`eventzr.review.created.v1`	New review created
`eventzr.review.published.v1`	Review status changed to published
`eventzr.review.updated.v1`	Review updated
`eventzr.review.deleted.v1`	Review deleted

AI & Sentiment3

Topic	Description
`eventzr.review.sentiment.computed.v1`	AI sentiment analysis completed for a review
`eventzr.review.flagged.v1`	Review flagged for moderation
`eventzr.review.moderated.v1`	Review moderation action taken (approved/rejected)

Social3

Topic	Description
`eventzr.review.reply.created.v1`	Reply created for a review
`eventzr.review.reply.updated.v1`	Reply to a review updated
`eventzr.review.shared.v1`	Review shared on social media

Import & Sync1

Topic	Description
`eventzr.review.imported.v1`	Review imported from external source (Google, Yelp, etc.)

Feedback2

Topic	Description
`eventzr.review.nps.recorded.v1`	NPS score recorded for a campaign
`eventzr.review.csat.recorded.v1`	CSAT score recorded

Disputes2

Topic	Description
`eventzr.review.dispute.created.v1`	Dispute filed against a review
`eventzr.review.dispute.resolved.v1`	Dispute against a review resolved