apache-kafka - Kafka 流式读写到单独的集群
问题描述
之前已经回答了一个类似的问题,但该解决方案不适用于我的用例。
我们在 2 个独立的 DC 中运行 2 个 Kafka 集群。我们的整体传入流量在这 2 个 DC 之间分配。
我将在每个 DC 中运行单独的 Kafka 流应用程序来转换该数据,并希望在单个 DC中写入 Kafka 主题。我怎样才能做到这一点?
最终我们将在 Druid 中索引 kafka 主题数据。由于我们正在尝试聚合数据,因此无法运行单独的 Druid 集群。
我读过它不可能使用单个 Kafka 流。有没有办法可以使用另一个 Kafka 流从 DC1 读取并写入 DC2 kafka 集群?
解决方案
正如您自己编写的那样,您不能使用 Kafka Streams API 从 Kafka 集群 A 读取并写入不同的 Kafka 集群 B。
相反,如果您想在 Kafka 集群之间移动数据(无论是在同一个 DC 中还是跨 DC),您应该使用诸如 Apache Kafka 的Mirror Maker或Confluent Replicator之类的工具。
推荐阅读
- apache-spark - spark + cassandra 上的性能相关问题(JAVA 代码)
- reactjs - 在 yarn start 命令中显示错误说 This package doesn't seem to be present in your lockfile; 尝试进行安装以更新您的分辨率
- xml - 后代包含父文本的所有节点的XPath?
- python - 如何从数据框制作 3D 条形图
- c# - 如何检查.NET中特定时区是否存在一个小时
- mysql - 如何使用 mysql 中的周数获取开始和结束周日期?
- python-3.x - 无法使用托管在 heroku 上的电报机器人刮掉歌词
- c++ - vivado hls 的可合成版本的问题
- rust - 借用和使用移动值
- javascript - 在 mailto 链接中使用时,换行符无法正确显示