我在 AWS 中使用 Kafka MSK。所以我们没有像 confluent 那样让原生 kafka 连接所有必需的连接器。 实际上,我使用kakfa mongo连接器,我想找到一种方法将kafka mongo连接器jar推送到kafka MSK集群实例上。 jar 将被推送到的路径是所用连接器的属性中定义的 plugins.path。
请问有什么办法吗?
MSK 不会为您提供托管的 Kafka Connect worker。您需要自己预置和运行它,例如在 EC2 上。然后,这项工作将连接到您的 Kafka 集群(在本例中为 MSK(
需要明确的是:MSK只是托管的Kafka经纪人(和Zookeeper(。它不包括Kafka Connect,这是运行连接器所需要的。