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

TopicMsg/minLag
product.recorder.transcription.completed
12 partitions · 168h retention
8.1K9.1K
product.recorder.meeting.started
8 partitions · 72h retention
4.7K673
ai.model.invocation
24 partitions · 336h retention
26.5K53.3K
ai.model.invocation.dlq
3 partitions · 720h retention
4491.1K
ai.agent.step.emitted
16 partitions · 168h retention
10.7K7.2K
billing.subscription.updated
6 partitions · 2160h retention
1.7K126
billing.invoice.paid
6 partitions · 2160h retention
1.4K79
billing.payment.failed
3 partitions · 2160h retention
574105
analytics.page.viewed
32 partitions · 72h retention
32K78K
analytics.feature.used
24 partitions · 168h retention
18.8K23.2K
identity.user.signed_up
4 partitions · 8760h retention
8418
identity.session.created
12 partitions · 72h retention
6.8K695

Pipeline jobs

CDC and ETL health

JobStatusRows 24h
Stripe billing CDC
Stripe → ClickHouse
Healthy47.1K
Paddle billing sync
Paddle → PostgreSQL
Healthy10.2K
PostHog product events
PostHog → Warehouse
Healthy2.3M
App Store Connect financials
Apple App Store → PostgreSQL
Degraded2.2K
Google Play revenue export
Google Play → S3 Raw Zone
Down896
LLM gateway usage rollup
Kafka ai.model.invocation → ClickHouse
Healthy5.1M
GitHub delivery metrics
GitHub → Warehouse
Healthy6.2K
Vercel deployment log drain
Vercel → ClickHouse
Healthy131.9K
Sentry issue stream
Sentry → PostgreSQL
Healthy47.2K
Prometheus remote write
Prometheus → ClickHouse
Healthy9.7M

Recent events

Live payload sample

TopicPayloadWhen
analytics.feature.used
p12 · offset 5315529 · recorder:949869
{"feature":"export_csv","product":"recorder","count":10}in 3h
ai.agent.step.emitted
p5 · offset 5152835 · legal-ai:389115
{"agent":"reconcile-agent","product":"legal-ai","step":12,"tool":"write_file"}in 3h
ai.model.invocation
p9 · offset 5215375 · translate-pro:884813
{"model":"gemini-3-flash","product":"translate-pro","in_tokens":16331,"out_toke…in 3h
identity.session.created
p3 · offset 4380282 · invoice-ai:982151
{"session":"ses_9144441","product":"invoice-ai","device":"mobile"}in 3h
ai.model.invocation
p14 · offset 5236542 · support-desk:655555
{"model":"claude-4.5-sonnet","product":"support-desk","in_tokens":3338,"out_tok…in 3h
analytics.feature.used
p11 · offset 4926582 · analytics-copilot:466807
{"feature":"slack_notify","product":"analytics-copilot","count":15}in 3h
ai.model.invocation
p2 · offset 4993686 · crm-copilot:645180
{"model":"gpt-5-mini","product":"crm-copilot","in_tokens":14636,"out_tokens":27…in 3h
analytics.page.viewed
p19 · offset 5314674 · recorder:132746
{"path":"/projects","product":"recorder","referrer":"direct"}in 3h
product.recorder.meeting.started
p1 · offset 4911435 · analytics-copilot:958538
{"meeting_id":"mtg_948192","product":"analytics-copilot","platform":"teams"}in 3h
analytics.page.viewed
p24 · offset 5683675 · translate-pro:348898
{"path":"/reports","product":"translate-pro","referrer":"google"}in 3h
product.recorder.transcription.completed
p3 · offset 5045416 · recorder:356468
{"meeting_id":"mtg_482755","product":"recorder","duration_s":685,"speakers":6,"…in 3h
ai.model.invocation
p11 · offset 5822495 · voice-studio:110306
{"model":"gpt-5-mini","product":"voice-studio","in_tokens":18698,"out_tokens":1…in 3h
analytics.page.viewed
p2 · offset 5950753 · invoice-ai:556910
{"path":"/settings/billing","product":"invoice-ai","referrer":"producthunt"}in 3h
product.recorder.meeting.started
p2 · offset 4971461 · resume-ai:960576
{"meeting_id":"mtg_303454","product":"resume-ai","platform":"google_meet"}in 3h
analytics.page.viewed
p29 · offset 5553283 · support-desk:527580
{"path":"/settings/billing","product":"support-desk","referrer":"producthunt"}in 3h
analytics.feature.used
p7 · offset 5590061 · resume-ai:775392
{"feature":"ai_summary","product":"resume-ai","count":9}in 3h