Core Platform
Replication Engine
Built with franz-go for high-throughput consuming and producing with same-name mirroring, exact or regex mappings. Source offsets commit only after the target produce is acknowledged.
Enterprise Dashboard
Operations, Health, Executive, and Compliance tabs. The UI polls the API; user-controlled text is HTML-escaped.
Hybrid Configuration
Base config from default.yml with runtime changes stored in SQLite for flexible deployment.
REST API + CLI
Full-featured Fiber API with admin CLI for bootstrapping and unified management CLI for operations.
Job Management
JobManager controls replication job lifecycle—start, stop, pause—with real-time status tracking.
Role-Based Security
Token auth with admin, operator, monitoring, and compliance roles. Cluster and config APIs mask credentials. Production binds the configured host and requires TLS unless allow_insecure is set.
Replication halt (experimental)
Off until an admin enables it. Freezes all jobs if the source cluster is compromised, so the replica stops copying the attack. Already-written kafscale/S3 objects stay read-only. Not a guarantee.
AI-Powered Insights
Anomaly Detection
Automatically detects anomalies in replication metrics and alerts operators.
Performance Tuning
Intelligent recommendations for optimizing replication throughput and latency.
Incident Analysis
Detailed AI-driven analysis of operational incidents with root cause insights.
Compliance Reporting
Automated daily/weekly/monthly reports with full audit trails.
RBAC & Security
Role-Based Security
Token-based authentication with admin, operator, monitoring, and compliance roles.
Admin & Management CLI
Unified command-line tools for bootstrapping, emergency maintenance, and day-to-day operations.