Kafka Events

8 event topics across 6 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 to Amazon MSK Serverless. llm-orch-svc is a producer only — it publishes events but does not consume from other services.

Brokers

Environment	Broker	Auth
Staging	`boot-gpm4u49z.c2.kafka-serverless.us-east-1.amazonaws.com:9098`	`SASL/OAUTHBEARER (IAM)`
Production	`b-1.eventzr-msk-prod.ap-south-1.amazonaws.com:9098`	`SASL/OAUTHBEARER (IAM)`

Event Envelope

CloudEvents 1.0 envelopejson

{
  "specversion": "1.0",
  "type": "eventzr.llm.usage.v1",
  "source": "llm-orch-svc",
  "id": "evt-550e8400-e29b-41d4-a716-446655440000",
  "time": "2026-02-27T12:00:00.000Z",
  "datacontenttype": "application/json",
  "subject": "tenant-uuid",
  "data": {
    "tenantId": "tenant-uuid",
    "userId": "user-uuid",
    "provider": "aws-bedrock",
    "model": "anthropic.claude-3-sonnet-20240229-v1:0",
    "useCase": "event-creation",
    "inputTokens": 150,
    "outputTokens": 350,
    "totalTokens": 500,
    "latencyMs": 1250,
    "costUsd": 0.0025,
    "cached": false
  }
}

Event Topics (8)

Usage & Telemetry2

Topic	Description
`eventzr.llm.usage.v1`	Usage telemetry after successful inference (tokens, cost, latency)
`eventzr.llm.semantic-cache.hit.v1`	Semantic cache hit — cached response served instead of provider call

Quota & Budget2

Topic	Description
`eventzr.llm.quota.low.v1`	Alert when credit balance drops below 20% threshold
`eventzr.llm.budget.exceeded.v1`	Budget ceiling breach — request rejected or flagged

Provider Health1

Topic	Description
`eventzr.llm.provider.outage.v1`	Provider circuit breaker state changed (open/half-open/closed)

Inference Lifecycle1

Topic	Description
`eventzr.llm.inference.failed.v1`	Inference failure after all retries exhausted across providers

Embeddings1

Topic	Description
`eventzr.llm.embeddings.generated.v1`	Embeddings generation completed (single or batch)

Knowledge Graph1

Topic	Description
`eventzr.llm.kg.synced.v1`	Knowledge graph sync completed — AI decisions recorded to Neptune