Event Streams
事件流Kafka/Pulsar topics, consumer lag and CDC pipelines feeding the warehouse.
18 topics9 degraded
Messages / sec
2K
173.7M / 24h
Bytes / sec
3.2 MB
Total lag
180.9K
Consumers
90
Topics
18
187 partitions
Degraded
9
Throughput
Messages over the last 24h
Consumer lag
Backlog by topic
Topics
Hottest streams
| Topic | Msg/min | Lag |
|---|---|---|
product.recorder.transcription.completed 12 partitions · 168h retention | 8.1K | 9.1K |
product.recorder.meeting.started 8 partitions · 72h retention | 4.7K | 673 |
ai.model.invocation 24 partitions · 336h retention | 26.5K | 53.3K |
ai.model.invocation.dlq 3 partitions · 720h retention | 449 | 1.1K |
ai.agent.step.emitted 16 partitions · 168h retention | 10.7K | 7.2K |
billing.subscription.updated 6 partitions · 2160h retention | 1.7K | 126 |
billing.invoice.paid 6 partitions · 2160h retention | 1.4K | 79 |
billing.payment.failed 3 partitions · 2160h retention | 574 | 105 |
analytics.page.viewed 32 partitions · 72h retention | 32K | 78K |
analytics.feature.used 24 partitions · 168h retention | 18.8K | 23.2K |
identity.user.signed_up 4 partitions · 8760h retention | 841 | 8 |
identity.session.created 12 partitions · 72h retention | 6.8K | 695 |
Pipeline jobs
CDC and ETL health
| Job | Status | Rows 24h |
|---|---|---|
Stripe billing CDC Stripe → ClickHouse | Healthy | 47.1K |
Paddle billing sync Paddle → PostgreSQL | Healthy | 10.2K |
PostHog product events PostHog → Warehouse | Healthy | 2.3M |
App Store Connect financials Apple App Store → PostgreSQL | Degraded | 2.2K |
Google Play revenue export Google Play → S3 Raw Zone | Down | 896 |
LLM gateway usage rollup Kafka ai.model.invocation → ClickHouse | Healthy | 5.1M |
GitHub delivery metrics GitHub → Warehouse | Healthy | 6.2K |
Vercel deployment log drain Vercel → ClickHouse | Healthy | 131.9K |
Sentry issue stream Sentry → PostgreSQL | Healthy | 47.2K |
Prometheus remote write Prometheus → ClickHouse | Healthy | 9.7M |
Recent events
Live payload sample
| Topic | Payload | When |
|---|---|---|
analytics.feature.used p12 · offset 5315529 · recorder:949869 | {"feature":"export_csv","product":"recorder","count":10} | 14h ago |
ai.agent.step.emitted p5 · offset 5152835 · legal-ai:389115 | {"agent":"reconcile-agent","product":"legal-ai","step":12,"tool":"write_file"} | 14h ago |
ai.model.invocation p9 · offset 5215375 · translate-pro:884813 | {"model":"gemini-3-flash","product":"translate-pro","in_tokens":16331,"out_toke… | 14h ago |
identity.session.created p3 · offset 4380282 · invoice-ai:982151 | {"session":"ses_9144441","product":"invoice-ai","device":"mobile"} | 14h ago |
ai.model.invocation p14 · offset 5236542 · support-desk:655555 | {"model":"claude-4.5-sonnet","product":"support-desk","in_tokens":3338,"out_tok… | 14h ago |
analytics.feature.used p11 · offset 4926582 · analytics-copilot:466807 | {"feature":"slack_notify","product":"analytics-copilot","count":15} | 14h ago |
ai.model.invocation p2 · offset 4993686 · crm-copilot:645180 | {"model":"gpt-5-mini","product":"crm-copilot","in_tokens":14636,"out_tokens":27… | 14h ago |
analytics.page.viewed p19 · offset 5314674 · recorder:132746 | {"path":"/projects","product":"recorder","referrer":"direct"} | 14h ago |
product.recorder.meeting.started p1 · offset 4911435 · analytics-copilot:958538 | {"meeting_id":"mtg_948192","product":"analytics-copilot","platform":"teams"} | 14h ago |
analytics.page.viewed p24 · offset 5683675 · translate-pro:348898 | {"path":"/reports","product":"translate-pro","referrer":"google"} | 14h ago |
product.recorder.transcription.completed p3 · offset 5045416 · recorder:356468 | {"meeting_id":"mtg_482755","product":"recorder","duration_s":685,"speakers":6,"… | 14h ago |
ai.model.invocation p11 · offset 5822495 · voice-studio:110306 | {"model":"gpt-5-mini","product":"voice-studio","in_tokens":18698,"out_tokens":1… | 14h ago |
analytics.page.viewed p2 · offset 5950753 · invoice-ai:556910 | {"path":"/settings/billing","product":"invoice-ai","referrer":"producthunt"} | 14h ago |
product.recorder.meeting.started p2 · offset 4971461 · resume-ai:960576 | {"meeting_id":"mtg_303454","product":"resume-ai","platform":"google_meet"} | 14h ago |
analytics.page.viewed p29 · offset 5553283 · support-desk:527580 | {"path":"/settings/billing","product":"support-desk","referrer":"producthunt"} | 14h ago |
analytics.feature.used p7 · offset 5590061 · resume-ai:775392 | {"feature":"ai_summary","product":"resume-ai","count":9} | 14h ago |