代码拉取完成，页面将自动刷新
Brooklin is a distributed system intended for streaming data between various heterogeneous source and destination systems with high reliability and throughput at scale. Designed for multitenancy, Brooklin can simultaneously power hundreds of data pipelines across different systems and can easily be extended to support new sources and destinations.
Extensible for any source and destination
Brooklin offers a flexible API that can be extended to support a wide variety of source and destination systems. It is not confined to single type of source or destination system.
Source and destination systems can be freely mixed and matched. They do not have to be the same.
Scalable
Brooklin supports creating an arbitrary number of data streams that are processed concurrently and independently such that errors in one stream are isolated from the rest.
Brooklin supports partitioned data streams throughout its core implementation and APIs.
Brooklin can be deployed to a cluster of machines (scale out) to support as many data streams as desired.
Easy to operate and manage
Brooklin exposes a REST endpoint for managing data streams, that offers a rich set of operations on them in addition to CRUD (e.g. pause and resume).
Brooklin also exposes a diagnostics REST endpoint that enables on-demand querying of a data stream’s status.
Battle-tested at scale with Kafka
While it is not limited to any particular system, Brooklin provides capabilities for reading/writing massive amounts of data to/from Kafka with high reliability at scale. You can learn more about this in the Use cases section.
Supports Change Data Capture with bootstrap
Brooklin supports propagating Change Data Capture events from data stores, e.g. RDBMS, KV stores … etc.
Brooklin also supports streaming a snapshot of the existing data before propagating change events.
Multitenancy
A single Brooklin cluster can be used to mirror data across several Kafka clusters.
Fault isolation across topic partitions
One bad partition will not affect an entire Kafka topic. Mirroring will continue for all the other healthy partitions.
Whitelisting topics using regular expressions
Select the topics to mirror using regular expression patterns against their names.
Pausing and resuming individual partitions
Through its Datastream Management Service (DMS), Brooklin exposes REST APIs that allow finer control over replication pipelines, like being able to pause and resume individual partitions of a Kafka topic.
Check out Mirroring Kafka Clusters to learn more about using Brooklin to mirror Kafka clusters.
Brooklin supports propagating Change Data Capture events from data stores, e.g. RDBMS, KV stores … etc.
Brooklin supports bootstrapping data from a datastore, i.e. streaming a snapshot of the existing data before any change events.
MySQL support is currently under development.
Brooklin can be used as the underlying streaming infrastructure feeding data to Stream Processing systems, e.g. Apache Samza, Apache Storm, Apache Spark, Apache Flink.
Feel free to check out our step-by-step tutorials for running Brooklin locally in a few example scenarios.
Join our Brooklin chat room on Gitter
File a bug or request features using GitHub issues
Copyright (c) LinkedIn Corporation. All rights reserved. Licensed under the BSD 2-Clause License.
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型
