【发布时间】:2020-12-13 01:13:34
【问题描述】:
我已经下载了二进制 Kafka 文件,然后是连接器的 Jar 文件。然后指定连接器 jar 的路径并配置连接到 mongo 的配置文件。
在我启动 zookkepper 后,运行 Kafka 并创建主题。如何启动连接器源?
【问题讨论】:
标签: mongodb apache-kafka apache-kafka-connect
我已经下载了二进制 Kafka 文件,然后是连接器的 Jar 文件。然后指定连接器 jar 的路径并配置连接到 mongo 的配置文件。
在我启动 zookkepper 后,运行 Kafka 并创建主题。如何启动连接器源?
【问题讨论】:
标签: mongodb apache-kafka apache-kafka-connect
Kafka bin 文件夹中有 connect-standalone 和 connect-distributed 脚本,用于运行 Kafka Connect。
您还需要编辑相应的属性文件以确保加载 Mongo 连接器插件
【讨论】: