mongodb-kafka-connector相关内容

MongoDB Kafka Sink 连接器不处理 RenameByRegex 处理器

我需要监听来自 Kafka Topic 和 Sink 的事件到 MongoDB 中的集合.消息包含一个带有 id 属性的嵌套对象，就像上面的例子一样. {“测试ID":1，"foo": "酒吧","foos": [{ "id":"aaaaqqqq-rrrrr" }]} 我正在尝试使用 RegExp 将此嵌套 id 重命名为 _id {"connector.class":"com.mongod ..
发布时间：2021-11-12 03:28:49 其他开发

Kafka-MongoDB Debezium 连接器:分布式模式

我正在研究 debezium mongodb 源连接器.我可以通过将 kafka 引导服务器地址作为远程机器(部署在 Kubernetes 中)和远程 MongoDB url 来以分布式模式在本地机器上运行连接器吗? 我试过了，我看到连接器成功启动，没有错误，只有很少的警告，但没有数据从 mongodb 流出. 使用以下命令运行连接器 ./bin/connect-distribute ..
发布时间：2021-11-12 03:28:26 其他开发

具有多个任务的分布式官方 Mongodb Kafka 源连接器不工作

我在我的 Windows 机器上运行 Apache Kafka，有两个 Kafka-Connect-Workers(端口 8083、8084)和一个具有三个分区的主题(一个复制).我的问题是，每当我关闭其中一个工作人员时，我都能看到故障转移到其他 Kafka-Connect 工作人员，但没有发生负载平衡，因为任务数量始终为 1.我使用官方 MongoDB-Kafka-Connector 作为源(C ..
发布时间：2021-11-12 03:28:09 其他开发

具有多个任务的分布式官方 Mongodb Kafka 源连接器不工作

我在我的 Windows 机器上运行 Apache Kafka，有两个 Kafka-Connect-Workers(端口 8083、8084)和一个具有三个分区的主题(一个复制).我的问题是，每当我关闭其中一个工作人员时，我都能看到故障转移到其他 Kafka-Connect 工作人员，但没有发生负载平衡，因为任务数量始终为 1.我使用官方 MongoDB-Kafka-Connector 作为源(C ..
发布时间：2021-11-12 03:28:03 其他开发

我们可以在 mongodb 中更新/更新记录吗?数据源是kafka

我们可以在 mongodb 中更新/更新记录，但是如果有任何方法或函数可以直接在 mongodb 中更新或更新文档，并且源系统是 kafka，目标是 mongodb. 解决方案 是的，我们可以更新/更新数据.对于更新，您必须在 Kafka 连接器中定义一个参数.并将要更新记录的基础列列入白名单.属性如下: document.id.strategy=com.mongodb.kafka.co ..
发布时间：2021-11-12 03:24:16 其他开发

Kafka-MongoDB Debezium 连接器:分布式模式

我正在研究 debezium mongodb 源连接器.我可以通过将 kafka 引导服务器地址作为远程机器(部署在 Kubernetes 中)和远程 MongoDB url 来以分布式模式在本地机器上运行连接器吗? 我试过了，我看到连接器成功启动，没有错误，只有很少的警告，但没有数据从 mongodb 流出. 使用以下命令运行连接器 ./bin/connect-distribute ..
发布时间：2021-11-12 02:53:17 其他开发

具有多个任务的分布式官方 Mongodb Kafka 源连接器不工作

我在我的 Windows 机器上运行 Apache Kafka，有两个 Kafka-Connect-Workers(端口 8083、8084)和一个具有三个分区的主题(一个复制).我的问题是，每当我关闭其中一个工作人员时，我都能看到故障转移到其他 Kafka-Connect 工作人员，但没有发生负载平衡，因为任务数量始终为 1.我使用官方 MongoDB-Kafka-Connector 作为源(C ..
发布时间：2021-11-12 02:51:28 其他开发

具有多个任务的分布式官方 Mongodb Kafka 源连接器不工作

我在我的 Windows 机器上运行 Apache Kafka，有两个 Kafka-Connect-Workers(端口 8083、8084)和一个具有三个分区的主题(一个复制).我的问题是，每当我关闭其中一个工作人员时，我都能看到故障转移到其他 Kafka-Connect 工作人员，但没有发生负载平衡，因为任务数量始终为 1.我使用官方 MongoDB-Kafka-Connector 作为源(C ..
发布时间：2021-11-12 02:49:29 其他开发

我们可以在 mongodb 中更新/更新记录吗?数据源是kafka

我们可以在 mongodb 中更新/更新记录，但是如果有任何方法或函数可以直接在 mongodb 中更新或更新文档，并且源系统是 kafka，目标是 mongodb. 解决方案 是的，我们可以更新/更新数据.对于更新，您必须在 Kafka 连接器中定义一个参数.并将要更新记录的基础列列入白名单.属性如下: document.id.strategy=com.mongodb.kafka.co ..
发布时间：2021-11-12 01:55:38 其他开发

Kafka-MongoDB Debezium连接器:分布式模式

我正在使用debezium mongodb源连接器.是否可以通过将kafka引导程序服务器地址指定为远程计算机(在Kubernetes中部署)和远程MongoDB url，以分布式模式在本地计算机上运行连接器? 我尝试了一下，发现连接器成功启动，没有错误，只有很少的警告，但没有数据从mongodb流出. 使用以下命令运行连接器 ./bin/connect-distributed ..
发布时间：2020-09-03 18:44:03 其他开发

我们可以在mongodb中更新/更新记录吗?数据源是kafka

我们可以在mongodb中更新/更新记录，但是有任何方法或功能可以直接在mongodb中更新或更新文档，源系统是kafka，目标系统是mongodb. 解决方案 是的，我们可以更新/更新数据. 要进行更新，您必须在Kafka连接器中定义一个参数. 并将您要更新记录所依据的列列入白名单.该属性如下: document.id.strategy=com.mongodb.kafka.conn ..
发布时间：2020-09-03 18:31:51 其他开发

具有多个任务的分布式Mongodb Kafka官方发布源连接器无法正常工作

我正在Windows机器上运行Apache Kafka，其中有两个Kafka-Connect-Workers(端口8083、8084)和一个带有三个分区的主题(一个副本). 我的问题是，每当我关闭其中一个时，我都能看到故障转移到其他Kafka-Connect工作程序，但是由于任务数始终为一，因此负载平衡没有发生. 我正在使用Task.max = 6的官方MongoDB-Kafka-Connecto ..
发布时间：2020-07-19 20:01:34 其他开发