如何使用 Java 代码使用 Kafka 连接器？答案

【问题标题】：How to use Kafka connector using java code?如何使用 Java 代码使用 Kafka 连接器？
【发布时间】：2020-12-27 18:41:40
【问题描述】：

目前我在独立模式下使用 Kafka SpoolDir 连接器。将所需的配置添加到属性文件后，我使用

启动连接器

kafka/bin/connect-standalone.sh connect-standalone.properties file-source.properties

有什么方法可以仅使用 java 代码启动连接器（stadalone/distributed），就像我们可以编写消费者和生产者 java 代码一样？

【问题讨论】：

【解决方案1】：

ConnectStandalone 是此命令启动的 Java 类，但 Connect Framework 并不打算作为嵌入式服务运行

你可以看到the source code here启动服务器并解析配置文件

【讨论】：

感谢您提供此信息。但我仍然有疑问的是，我正在尝试实现的 Kafka 连接器是否要投入生产。这就是为什么我正在寻找一种使用java的方法。我应该怎么做？如果这是一个愚蠢的问题，我很抱歉，我对此完全陌生。
链接代码是“使用Java”。您询问的那个shell脚本运行我链接到的类......但是，您应该使用connect-distributed。 Kafka 连接器通常是放置在生产服务器的 plugin.path 配置上的 JAR 文件（参见 connect-distributed.properties）。
好的。所以我应该使用connect-distributed并在添加属性文件后，仅使用相应的shell命令启动连接器，这样是否正确？
属性文件已经可以从任何 Kafka 安装中获得。 docs.confluent.io/current/connect/concepts.html
哦，是的，我的意思是自定义属性。但我明白你的意思。谢谢！