假设您有一个业务应用程序在其自己的环境中生成和存储丰富的产品主数据，您希望在 CouchBase 数据库上提供该数据。
为了将业务应用程序环境中的数据导入 CouchBase，假设我想使用 Kafka 广播更改并使用 Nifi 将其分发到最终目的地（CouchBase）。
但 CouchBase 采用 JSON 格式文件。我可以使用 Kafka 或 Nifi 将拉取的数据转换为 JSON 格式吗？我知道我可以在业务应用程序和 Kafka 之间放置诸如 Attunity 之类的解决方案来实时复制数据。但是让我们假设没有预算来实施解决方案，因此将暂时在业务应用程序端使用 REST API 并使用（基于所做的更改）Kafka 提取该数据，然后我将数据转换为 JSON卡夫卡？还是 NiFi？
编辑：
好吧，我想知道 NiFi 是否可以做到这一点的原因是因为我们的环境比我描述的要复杂一些。因为在 CouchBase 和业务应用程序之间，您有：[Business App] - [ X ] - [Kafka] - [NiFi] - [DC/OS with KONG API Layer] - [CouchBase Cluster]。
我想知道我是否应该在 X 现场实施一个新的数据复制解决方案，还是应该只使用 Business App REST API 并使用 Kafka 从 REST API 中提取数据并将我的数据转换为 JSON镍铁。