我已经下载了二进制Kafka的文件,然后jar文件的conector。然后指定了连接器jar的路径,并配置了与mongo连接的配置文件。启动zookkepper后,运行kafka并创建主题。如何启动连接器源?
pgpifvop1#
有 connect-standalone 以及 connect-distributed kafka bin文件夹中用于运行kafka connect的脚本。您还需要编辑相应的属性文件,以确保mongo连接器插件已加载
connect-standalone
connect-distributed
1条答案
按热度按时间pgpifvop1#
有
connect-standalone
以及connect-distributed
kafka bin文件夹中用于运行kafka connect的脚本。您还需要编辑相应的属性文件,以确保mongo连接器插件已加载