我建立了一个DWH架构，其中多个小型mysql数据库将入库到一个更大的mysql数据库中。 我在源数据库中使用 Binlog，然后使用 Nifi capturechangeMysql 处理器读取更改并在将它们放入目标 Mysql 之前进行一些小的转换。
Source_DBs ->> Nifi ->> Destination_DB
为什么以及如何在此架构中使用消息代理（kafka）？