从 Kafka 加载数据
Kafka Foreign Data Wrapper (FDW) 提供了 Apache Cloudberry 与 Apache Kafka 连接的能力,使得数据库能够直接从 Kafka 中读取数据,并将其作为外部表来处理。Apache Cloudberry 用户可以更高效、灵活、可靠地处理 Kafka 中的实时数据,从而提高数据处理能力和业务效率。
Apache Cloudberry 支持使用 Kafka FDW 来创建外部表以及导入数据。
更多信息,参考 Kafka FDW 仓库:https://github.com/cloudberry-contrib/kafka_fdw。注意,该仓库由社区成员贡献,但不是由 PPMC 维护的官方社区项目。
基本使用
-
创建
kafka_fdw
扩展。CREATE EXTENSION kafka_fdw;