当前我在独立模式下使用Kafka SpoolDir连接器。在将所需的配置添加到属性文件后，我使用启动连接器
kafka/bin/connect-standalone.sh connect-standalone.properties file-source.properties
是否有任何方法可以仅使用java代码启动连接器(stadonne/distributed(，就像我们可以编写消费者和生产者的java代码一样？
ConnectStandalone是该命令启动的Java类，但Connect Framework并不意味着作为嵌入式服务运行
您可以在这里看到启动服务器并解析配置文件的源代码