我正在使用Confluent Platform v5.4，Mongo DB 3.6版和Kafka Mongo DB连接器。我已经配置了Kafka Mongo DB源连接器，以

我已经设置了一个非常简单的<a href="https://docs.mongodb.com/kafka-connector/master/kafka-source/" rel="nofollow noreferrer">

我正在尝试将数据从单一来源写入多个DataSink（Mongo和Postgres DB）。 传入数据 <pre><code>Dataset&lt;Row&gt; df

如何使用Kafka Connect从kafka消息中检索传入的标头，以使用MongoDB Sink Connector到mongodb将它们存储为其他数据

我在mongoDB中具有以下三个集合： <pre><code>//Drinkers { &#34;drinkerId&#34; : &#34;ID1&#34;, &#34;name&#34; : &#3

我是Kafka的新手，我想看看是否可以使用Kafka将MongoDb数据与另一个系统同步。 我的设置： <ol> <li

我正在使用 Kafka Connect MongoSourceConnector 将数据从数据库读取到 Kafka。这是可行的，但它总是以奇怪的 Mong

我想使用 <strong>Mongo-Kafka 连接器</strong> 在我们的微服务中实现 <strong>发件箱模式</strong>，在我的发件箱

我正在使用源连接器的以下配置来过滤和读取来自 MongoDB 的状态为“PENDING”的特定记录。只需要轮询所

我遇到了尽管运行和操作我的主题并没有注册在我的 MongoDB 中发生的事件。 每次我插入/修改记录

我一直在寻找有关 Kafka Connect 连接器高可用性部署的具体信息，但一无所获。 就我而言，我使用 <a

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

我使用 <a href="https://www.mongodb.com/blog/post/getting-started-with-the-mongodb-connector-for-apache-kafka-and-mongodb-atlas" rel="

我正在尝试设置 mongodb 接收器连接器，但在启动时出现错误 错误： <pre class="lang-json prettyprint-ove

我已经设置了 Kafka 集群并在 <code>confluent-hub</code> 实例上安装了 <code>EC2</code>。我已经下载了 <code>confluent

我正在尝试将数据从 Mongo 添加到 Kafka 主题。但我在启动后发现了这样的异常： <pre><code>Caused by: java.l

我有一个 Kafka Connect MongoDB 源连接器（都通过 Confluent 平台）工作，但它创建的消息在开始时包含一个控

1;我尝试使用 valuetokey 更改分区键，但出现错误“仅支持 Struct 对象 [将字段从值复制到键]，找到：java.la

我在源连接器中工作，以观察 Mongo 集合中的更改并将它们带到 Kafka 主题。这很好用，直到我添加要求，

在 Mongo 到 Kafka 连接器上工作并遇到这个问题，当消息从 mongo 转储到 kafka 主题时，它会添加斜杠 <pre>