Kafka Events

14 published and 5 consumed event topics across the Subscriptions Service.

Event Format: CloudEvents 1.0

All events follow the CloudEvents 1.0 specification. Events are partitioned by tenant_id and published to Amazon MSK Serverless.

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.subscription.created.v1",
  "source": "subscriptions-svc",
  "id": "evt-550e8400-e29b-41d4-a716-446655440000",
  "time": "2026-02-24T12:00:00.000Z",
  "datacontenttype": "application/json",
  "subject": "tenant-uuid",
  "data": {
    "tenantId": "tenant-uuid",
    "subscriptionId": "sub-uuid",
    "actorType": "user",
    "actorId": "user-uuid",
    "planId": "plan-uuid",
    "tier": "PRO",
    "billingCycle": "monthly",
    "status": "active"
  }
}

Published Events (14)

Subscription Lifecycle7

Topic	Description
`eventzr.subscription.created.v1`	New subscription created
`eventzr.subscription.upgraded.v1`	Subscription upgraded to higher tier
`eventzr.subscription.downgraded.v1`	Subscription downgraded to lower tier
`eventzr.subscription.cancelled.v1`	Subscription cancelled
`eventzr.subscription.paused.v1`	Subscription paused
`eventzr.subscription.resumed.v1`	Paused subscription resumed
`eventzr.subscription.reactivated.v1`	Cancelled subscription reactivated

Payment & Billing2

Topic	Description
`eventzr.subscription.payment_succeeded.v1`	Payment successfully processed
`eventzr.subscription.payment_failed.v1`	Payment processing failed

Quotas1

Topic	Description
`eventzr.subscription.quota_exceeded.v1`	Subscription quota exceeded

Trial Lifecycle3

Topic	Description
`eventzr.subscription.trial_started.v1`	Trial period started
`eventzr.subscription.trial_progressed.v1`	Trial progressed to next phase
`eventzr.subscription.trial_ended.v1`	Trial period ended

Referrals1

Topic	Description
`eventzr.subscription.referral_applied.v1`	Referral code applied successfully

Consumed Events (5)

Topic	Description
`eventzr.tenant.created.v1`	Auto-provisions BASE-tier subscription for new tenant
`eventzr.user.created.v1`	May trigger default subscription provisioning
`eventzr.user.deleted.v1`	Triggers subscription cleanup
`eventzr.wallet.transaction.completed.v1`	Payment reconciliation
`eventzr.payments.webhook.received.v1`	External payment provider webhook