KafkaMSK上的Kafka连接mongo
我正在AWS中使用Kafka MSK。因此，我们没有原生kafka连接到所有必需的连接器，例如confluent。实际上，我使用kakfa mongo连接器，我想找到一种方法，将kafka mongo连接器jar推送到kafka MSK集群实例上。jar将被推送到的路径是插件。所用连接器的属性中定义的路径。
有什么办法吗？
共有1个答案
MSK不会提供托管的Kafka Connect worker。您需要自己设置并运行它，例如在EC2上。然后，这项工作将连接到您的Kafka集群（本例中为MSK）
需要明确的是：MSK只是托管的Kafka代理（和ZooManager）。它不包括Kafka Connect，这是您运行连接器所需要的。
-
我需要帮助，因为我对Kafka和mqtt一无所知。我正在使用docker compose创建Mosquitto broker和Kakfa之间通信的架构 我还使用confluent Kafka Connect MQTT（https://www.confluent.io/hub/confluentinc/kafka-connect-mqtt) 它对于1883端口上的通信工作得很好，但当我尝试在8883
-
我有一个kafka connect插件，部署在kafka集群中（在独立模式下，仅用于测试，目的是分布式完成）。这个Kafka连接插件使用curator连接到集群的zookeper，并从中提取一些信息，以决定如何处理这些消息。 代码如下： 在treeCache启动时超时，配置根路径存在于本地zookeeper中（已确认在zookeeper外壳中执行ls，对于我尝试使用的zkConnection字符串
-
下面是/etc/kafka/connect-MongoDB-source.properties中的MongoDB配置 但是低于误差 以独立模式运行连接器。 我在debezium-debezium-连接器-mongob-1.0.0/debezium-connector-mongodb-1.0.0.Final.jar 类路径的设置如下 使用插件路径，我看到它能够注册和加载所有必需的插件。 但最后还是同
-
我使用kafka connect从mongo读取数据并将其写入kafka主题。 我正在使用 mongo kafka 源连接器。 我收到以下错误： 罐子里好像有一个小盒子。为了得到这个罐子，我使用了两种不同的方法，但是我得到了同样的错误。首先，我使用了下载的from:maven资源库，然后我从github repo中克隆了源代码，并自己构建了jar。我将jar推到plugins.path中，当我解压
-
我有两个Kafka主题-和。第一个主题包含由唯一Id（称为）键入的recommendations对象。每个产品都有一个用户可以单击的URL。 主题获取通过单击推荐给用户的产品URL生成的消息。它是如此设置的，这些单击消息也由键控。 请注意 > 每个单击对象都会有一个相应的推荐对象。 click对象的时间戳将晚于Recommensions对象。 建议和相应的点击之间的间隔可能是几秒钟到几天（最多7天
-
我正在尝试使用CockroachDB (v2.0.6)作为我的一个Kafka主题的接收器。 我找不到任何专门用于CockroachDB的Kafka连接器，所以我决定使用Confluent的jdbc sink连接器，因为CockroachDB支持postgreSQL语法。 我在Kafka Connect上使用的连接字符串如下 这基本上是我在现有工作的Postgres接收器连接器上所做的唯一更改。 不