Self-hosted bridge that connects any Kafka topic to any HTTP app with no Kafka client code, built solo from an empty repo. One Go binary, one YAML file, and a React console.

• At-least-once delivery with in-order commits, retries with backoff, per-key ordering, dead-letter and reject topics, and a circuit breaker

• Flows as a DAG: conditions, data checks, fan-out to several apps, webhooks, and topics, with a separate line for every answer, reject, and failure

• Ready-made steps for OpenSearch, Elasticsearch, NiFi, another Kafka cluster, Slack, Discord, and Teams

• Cluster mode coordinated through Kafka itself: leader election, label-based placement, failover in about a second

• Built-in MCP server and assistant that diagnose pipelines and draft config changes applied only after a confirmed preview

• Live React Flow canvas where each dot is ten real messages

• gosec, Semgrep, govulncheck, OSV-Scanner, Gitleaks, Trivy, and CodeQL on every push