当前位置: 首页 > 知识库问答 >
问题:

Apache Kafka与MongoDB-4.0的官方MongoDB源连接器

齐甫
2023-03-14

我有一个要求,我必须捕获MongoDB ChangeStream(插入/更新等)事件并采取一些操作(保存到OracleDB)。我想到了这个似乎不错的设计:

“MongoDB-ChangeStream”--

我这里的问题是,我使用的是MongoDB-4.0,MongoDB-4.2中引入了“MongoDB Source Connector for Apache Kafka”。我还可以在MongoDB-4.0中使用“MongoDB Source Connector for Apache Kafka”吗?

Apache Kafka的MongoDB源连接器-官方页面:https://www.confluent.io/hub/mongodb/kafka-connect-mongodb

“用于Apache Kafka的MongoDB源连接器”的官方页面没有讨论MongoDB版本的任何先决条件。

我的第二个问题,这个(Apache Kafka的MongoDB源连接器)可以在Windows上设置吗?

感谢您的帮助。


共有2个答案

柯鸿振
2023-03-14

>

启动Kafka-Connect:bin\windows\connect-standalone.batconfig\connect-standalone.propertiesF:\soft\mongodb\mongodb-kafka-Connect-mongodb-1.1.0\etc\MongoSourceConnector.properties

易琛
2023-03-14

答案已经在留档了:

如果您仅对集合使用更改流,则Kafka源连接器需要MongoDB 3.6或更高版本作为您的数据源。如果需要监视数据库或部署,则需要MongoDB 4.0或更高版本。

关于你的第二个问题;是的,在Windows上运行Kafka是可能的。

 类似资料:
  • 我正在windows 10上安装mongoDb 4.0,并遵循了安装指南。mongodb服务器正在作为服务运行。当我打开命令提示符并键入:mongod时,我收到以下消息: 2018-07-13T13:47:41.173 0200I NETWORK[initand听]在端口27017上等待连接 当我键入mongo时,会出现以下错误: MongoDB shell version v4.0.0连接到:m

  • 目前我在一个需要php的web项目中工作 这些都是我用过的技术 Wampserver 3.1.7 Apache 2.4.37 PHP7.2。14 mongoDB 4.20 mongo-php驱动程序7.2线程安全(Ts)x64 我所做的是: 已在C:\Program文件上安装mongodb 已在C上安装wampserver:\ 将C:\Program Files\MongoDB\Server\4.

  • 我对React和Node还不熟悉,尽管我的代码有几天没有出现错误,但今天我的终端出现了错误,我无法连接到我的mongo数据库。我使用节点服务器运行服务器。js命令,但我得到了错误。有人能帮我找到解决办法吗?谢谢 错误 服务器正在端口5000上运行(节点:3339)DeprecationWarning:当前的服务器发现和监控引擎已弃用,并将在未来的版本中删除。要使用新的服务器发现和监控引擎,请将选项

  • 我面临mongo DB连接问题。 我成功地将tMongo组件导入我的Talend Open Studio 5.1.1,并复制了mongo 1.3。jar文件到lib/java文件夹,我的Mongo DB作业正在成功运行,但问题是,即使我为mongoDB提供了一些假服务器路径(IP)和假端口,我的作业运行时没有出现错误,它给了我一行没有数据的数据。正确的IP和端口也是如此。 我如何解决它。

  • MongoDB是一种文档导向数据库管理系统,由C++撰写而成。 本章节我们将为大家介绍如何使用 Node.js 来连接 MongoDB,并对数据库进行操作。 如果你还没有 MongoDB 的基本知识,可以参考我们的教程:MongoDB 教程。 安装驱动 本教程使用了淘宝定制的 cnpm 命令进行安装: $ cnpm install mongodb 接下来我们来实现增删改查功能。 创建数据库 要

  • 我已经尝试了以下代码: 但它显示了一些错误: New-Object:异常调用". ctor"与"1"参数:"无法加载文件或程序集"System.运行时。InteropServices.RuntimeInformation, Version=4.0.0.0,'区域性=中性, PublicKeyToken=b03f5f7f11d50a3a'或其依赖项之一。系统找不到指定的文件。" at D:\用户\x