BriData/DBus

Health v2 · maintenance only

Adoption not part of the score

1214 stars · 530 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

DBus is a Java-based data bus platform that captures incremental changes from databases (via log-based CDC) and log sources in a non-intrusive way, transforms them into a unified JSON message format (UMS), and publishes them to Kafka for downstream consumption. It includes multi-tenant routing with per-tenant permissions and real-time data masking, plus heartbeat monitoring and schema-change detection.

Use cases

• stream mysql binlog changes to kafka in real time
• build a real-time data warehouse feed from operational databases
• sync data between heterogeneous systems with second-level latency
• mask sensitive columns before distributing data to tenants
• detect and notify downstream consumers of source schema changes
• capture and structure application logs via logstash/flume/filebeat
• perform initial full load of tables into a message stream

When to choose

• you need non-intrusive, log-based CDC from MySQL into Kafka
• you need multi-tenant data isolation with per-tenant masking and access control
• you want a unified JSON message protocol (UMS) for change events including insert/update/delete
• you run a Storm/Kafka big-data stack and want real-time streaming pipelines

When to avoid

• you only need simple batch ETL without real-time requirements
• your stack does not include Kafka, ZooKeeper, and Storm
• you need a lightweight single-binary CDC tool rather than a full platform with web management
• you primarily use databases other than MySQL (open-source version focuses on MySQL)
• you want an actively evolving project - releases have been infrequent since 2022

Facets

application · maturity maintenance

streaming etl message-queue monitoring security configuration-management big-data databases analytics jvm self-hosted cdc data-bus kafka storm canal change-data-capture multi-tenant data-masking ums log-based-replication data-engineering real-time linux docker

Member repositories

For agents

markdown · JSON · MCP: product_card(name="BriData/DBus")