首页 文章

设置kafka-connect以从远程代理获取数据

提问于
浏览
0

我正在尝试设置Kafka连接接收器连接器 . Kafka connect是Kafka connect worker的一部分(confluent-3.2.0) . 我在机器A上启动并运行了Kafka代理(confluent-3.2.0) . 我想在另一台机器B上设置Kafka-connect-sink连接器以使用自定义Kafka-connect-sink连接器jar来消息消息 . 假设机器A上的Kafka代理和Zoo守护端口对机器B开放 .

因此,我应该在机器B上安装/设置confluent-3.2.0(因为Kafka Connect是Kafka软件包的一部分),方法是将类路径设置为Kafka-connect-sink连接器jar并运行以下命令?

./bin/connect-distributed.sh worker.properties

1 回答

  • 1

    是 . 您描述的内容将起作用并且是设置此系统的最简单方法,即使在机器B上您实际上只需要启动脚本,配置属性文件,Kafka Connect的jar和自定义连接器的jar .

相关问题