【发布时间】:2017-11-11 08:59:48
【问题描述】:
我正在尝试设置 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 broker 和 Zoo keeper 端口对机器 B 开放。
那么我是否应该通过将类路径设置为 Kafka-connect-sink 连接器 jar 并运行以下命令,在机器 B 上安装/设置 confluent-3.2.0(因为 Kafka Connect 是 Kafka 包的一部分)?
./bin/connect-distributed.sh worker.properties
【问题讨论】:
标签: apache-kafka remote-server apache-kafka-connect