问题标签 [mongodb-kafka-connector]

我正在使用 MongoDB Kafka 连接器，我能够成功创建和更新记录，但无法删除连接器配置中的记录我正在使用这个配置

}

如果我发送空记录文档更新为空而不删除任何想法，则无法删除记录？

我使用本指南来设置 mongodb 连接器。

该指南没有解释如何执行以下操作，如何运行连接器。

使用该配置启动 Connect 工作人员。Connect 将发现这些插件中定义的所有连接器。

mongodb连接器的所有文件都放在路径中：

/home/user/Desktop/kafka-2.7.0-src/plugins/mongodbconnector

你能帮忙吗？

我正在尝试设置一个 mongodb 接收器连接器，但是当我启动它时出现错误

错误：

进一步挖掘日志文件，我发现了这两个错误：

我的系统配置：

融合-kafka-connect.service

卷曲命令

日志

我正在使用这个文档来创建密钥和信任链

任何想法如何解决这个问题？

我已经设置了 Kafka 集群并安装confluent-hub在一个EC2实例上。我已经下载了confluent-hubtar 文件，解压缩并将二进制文件放入/usr/local/bin.

当我现在尝试安装任何连接器时，我得到了 ClassNotFoundException。

我哪里错了？

我正在尝试将数据从 Mongo 添加到 Kafka 主题。但是我在启动后发现了这样的异常：

检查可用的连接器列表后，我看到了这个类

我的错误在哪里？谢谢！我的连接配置：

我有一个 Kafka Connect MongoDB 源连接器（均通过 Confluent 平台）工作，但它创建的消息在开始时包含一个控制字符，这使得该消息的下游解析（到 JSON）比我想象的更难。

正在运行的源连接器：

此 Source 连接器在 Kafka 主题中创建的消息如下（注意前导控制字符）：

控制字符使下游解析为 JSON 变得困难，因为它使原本有效的 JSON 无效。我不知道它为什么存在或如何摆脱它。

我想，我可以在像 JSON 一样对待它之前解析出像这个控制字符这样的垃圾，但这似乎是我想避免的创可贴。

我现在处理消息的方式，我认为这是无关紧要的，因为我已经测试过它可以在没有控制字符的情况下使用有效的 JSON，如果它很重要，如下所示：

任何想法表示赞赏。

1个；我尝试使用 valuetokey 更改分区键，但出现错误“仅支持 [将字段从值复制到键]的结构对象，发现：java.lang.String”；2；我想更新返回结构类型的源代码 MongoSourceTask.poll()，但无法更改；

怎么解决，谢谢

我正在使用源连接器来观察 Mongo 集合中的变化并将它们带到 Kafka 主题。如果满足特定条件（名称= Kathe），这很好，直到我添加了将它们放入 Kafka 主题的要求。这意味着只要更新过程将名称更改为 Kathe，我就需要将数据放入主题中。

我的连接器的配置如下所示：

我也试过

但是当条件满足时，它不会产生消息。

我犯错了吗？

在 Mongo 到 Kafka 连接器上工作并遇到消息从 mongo 转储到 kafka 主题时添加斜杠的问题

嗨，在我的 POC 中，我同时使用接收器和源 mongodb 连接器。
接收器连接器工作正常。但是源连接器不会将数据推送到结果主题中。目标是在集合调用“请求”中推送所有更改（插入和更新）的完整文档。

下面是代码。

没有消息被推送到 proj.request 主题。一旦我在集合“请求”中插入记录，就会创建主题。

在这方面获得帮助会很棒，因为它是 POC 的成败任务。在融合云上的连接器上一切正常。但它是我需要让它工作的前提设置。