Kafka Events

38 event topics across 9 categories published to Amazon MSK Serverless.

Event Format: CloudEvents 1.0

All events follow the CloudEvents 1.0 specification. Events are partitioned by tenant_id and published via the transactional outbox pattern (outbox-publisher polls every 10 seconds).

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.integration-hub.execution.completed.v1",
  "source": "integration-hub-svc",
  "id": "evt-550e8400-e29b-41d4-a716-446655440000",
  "time": "2026-02-24T12:00:00.000Z",
  "datacontenttype": "application/json",
  "subject": "tenant-uuid",
  "data": {
    "tenantId": "a0000001-0000-0000-0000-000000000001",
    "executionId": "exec-123",
    "providerKey": "stripe",
    "intent": "payment.create",
    "status": "SUCCESS",
    "durationMs": 342
  }
}

Event Topics (38)

Provider Lifecycle4

Topic	Description
`eventzr.integration-hub.provider.created.v1`	New provider registered
`eventzr.integration-hub.provider.updated.v1`	Provider configuration updated
`eventzr.integration-hub.provider.disabled.v1`	Provider disabled
`eventzr.integration-hub.provider.health-check.completed.v1`	Provider health check completed

Credential Lifecycle4

Topic	Description
`eventzr.integration-hub.credential.bound.v1`	Credential bound to provider
`eventzr.integration-hub.credential.rotated.v1`	Credential rotated
`eventzr.integration-hub.credential.revoked.v1`	Credential revoked
`eventzr.integration-hub.credential.expired.v1`	Credential expired

Execution4

Topic	Description
`eventzr.integration-hub.execution.started.v1`	Integration execution started
`eventzr.integration-hub.execution.completed.v1`	Execution completed successfully
`eventzr.integration-hub.execution.failed.v1`	Execution failed after retries
`eventzr.integration-hub.usage.recorded.v1`	Usage metrics recorded for billing

OAuth Connections4

Topic	Description
`eventzr.integration-hub.oauth.connected.v1`	OAuth connection established
`eventzr.integration-hub.oauth.refreshed.v1`	OAuth token refreshed
`eventzr.integration-hub.oauth.revoked.v1`	OAuth connection revoked
`eventzr.integration-hub.oauth.expired.v1`	OAuth token expired

Marketplace & Integrations5

Topic	Description
`eventzr.integration-hub.marketplace.published.v1`	Integration published to marketplace
`eventzr.integration-hub.integration.installed.v1`	Integration installed by tenant
`eventzr.integration-hub.integration.enabled.v1`	Installed integration enabled
`eventzr.integration-hub.integration.disabled.v1`	Installed integration disabled
`eventzr.integration-hub.integration.uninstalled.v1`	Integration uninstalled

WhatsApp Messaging6

Topic	Description
`eventzr.integration-hub.whatsapp.message.sent.v1`	WhatsApp message sent
`eventzr.integration-hub.whatsapp.message.delivered.v1`	WhatsApp message delivered
`eventzr.integration-hub.whatsapp.message.read.v1`	WhatsApp message read
`eventzr.integration-hub.whatsapp.message.failed.v1`	WhatsApp message delivery failed
`eventzr.integration-hub.whatsapp.template.synced.v1`	Templates synced from Meta
`eventzr.integration-hub.whatsapp.webhook.received.v1`	Webhook event received from Meta

Sync Jobs3

Topic	Description
`eventzr.integration-hub.sync.started.v1`	Data sync job started
`eventzr.integration-hub.sync.completed.v1`	Data sync job completed
`eventzr.integration-hub.sync.failed.v1`	Data sync job failed

Budget & Compliance3

Topic	Description
`eventzr.integration-hub.budget.threshold-reached.v1`	Budget threshold reached
`eventzr.integration-hub.cost-anomaly.detected.v1`	Cost anomaly detected
`eventzr.integration-hub.compliance.violation.v1`	Compliance policy violation

Outbox & Webhooks3

Topic	Description
`eventzr.integration-hub.outbox.published.v1`	Outbox event published to Kafka
`eventzr.integration-hub.webhook.dispatched.v1`	Webhook event dispatched
`eventzr.integration-hub.webhook.failed.v1`	Webhook delivery failed