目前，我使用Kafkaspooldir连接器在独立模式。将所需配置添加到属性文件后，我使用
kafka/bin/connect-standalone.sh connect-standalone.properties file-source.properties有没有什么方法可以像编写使用者和生产者java代码那样，只使用java代码启动连接器（stadalone/distributed）？
目前，我使用Kafkaspooldir连接器在独立模式。将所需配置添加到属性文件后，我使用
kafka/bin/connect-standalone.sh connect-standalone.properties file-source.properties有没有什么方法可以像编写使用者和生产者java代码那样，只使用java代码启动连接器（stadalone/distributed）？
1条答案
按热度按时间wqnecbli1#
ConnectStandalone是该命令启动的java类，但connect framework并不打算作为嵌入式服务运行您可以在这里看到启动服务器并解析配置文件的源代码