我正在设置Kafka连接接收器连接器。kafka connect是kafka connect worker(confluent-3.2.0)的一部分。我有一个kafka代理(confluent-3.2.0)在机器a上运行。我想在另一台机器b上设置kafka connect sink connector来使用消息,使用自定义kafka connect sink connector jar。假设机器a上的kafka broker和zoo keeper端口对机器b开放。
那么,我是否应该在机器b上安装/设置confluent-3.2.0(因为kafka connect是kafka包的一部分),方法是将类路径设置为kafka connect接收器连接器jar并运行以下命令? ./bin/connect-distributed.sh worker.properties
1条答案
按热度按时间ghhaqwfi1#
对。您所描述的将起作用,并且是设置此系统的最简单方法,即使在机器b上您实际上只需要开始脚本、配置属性文件、kafka connect的jar和自定义连接器的jar。