我正在尝试设置 Kafka 连接接收器连接器。Kafka connect 是 Kafka connect worker (confluent-3.2.0( 的一部分。我有一个 Kafka 代理(confluent-3.2.0(在机器 A 上启动并运行。我想在另一台机器 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
是的。您描述的内容将起作用，并且是设置此系统的最简单方法，即使在计算机 B 上您实际上只需要启动脚本、配置属性文件、Kafka Connect 的 jar 和自定义连接器的 jar。