如何使用 java 代码使用 Kafka 连接器？
How to use Kafka connector using java code?
目前我在独立模式下使用 Kafka SpoolDir 连接器。将所需配置添加到属性文件后，我使用
启动连接器
kafka/bin/connect-standalone.sh connect-standalone.properties file-source.properties
有什么方法可以仅使用 java 代码来启动连接器（stadalone/分布式），就像我们可以编写消费者和生产者 java 代码一样？
ConnectStandalone 是此命令启动的 Java class，但 Connect Framework 并不意味着 运行 作为嵌入式服务
可以看到the source code here启动服务器并解析配置文件
目前我在独立模式下使用 Kafka SpoolDir 连接器。将所需配置添加到属性文件后，我使用
启动连接器kafka/bin/connect-standalone.sh connect-standalone.properties file-source.properties
有什么方法可以仅使用 java 代码来启动连接器（stadalone/分布式），就像我们可以编写消费者和生产者 java 代码一样？
ConnectStandalone 是此命令启动的 Java class，但 Connect Framework 并不意味着 运行 作为嵌入式服务
可以看到the source code here启动服务器并解析配置文件