The engineering toolkit for real-time data

kJQ search across hundreds of topics in seconds. Filter by key, header, or message content with JQ-like syntax. Regex topic matching, multi-topic search, streaming search for live debugging. No throwaway consumers.

Manage topics, ACLs, consumer groups, schemas, and connectors in one place. Create, inspect, edit, delete. Reset offsets, skip poison pills, reassign partitions, diff schema versions. Full lifecycle, full audit trail.

Monitor consumer lag by partition, host, and broker. Real-time dashboards surface under-replicated partitions, stalled consumers, and throughput bottlenecks. Prometheus endpoints feed your existing observability stack.

Track every job's health at a glance. See running, failed, and restarting jobs across clusters, with checkpoint duration and backpressure surfaced immediately.

Deploy and manage jobs without the CLI. Submit, savepoint, scale, and cancel jobs from the UI. Full parameter and configuration history for every deployment.

Diagnose bottlenecks by operator. Drill into task-level metrics, watermark skew, and state size to find the operator that's actually slowing the pipeline.

See snapshot history and schema evolution at a glance. Real-time visibility into snapshots, partition specs, and schema history across every catalog and query engine writing to your tables.

Trigger table maintenance on demand. Run compaction, snapshot expiry, and orphan file cleanup from a clean UI instead of ad-hoc scripts and cron jobs.

One view across every catalog. Manage tables across every catalog and query engine writing to your Iceberg lake, instead of piecing it together by hand.