根据官方文档(https://camel.apache.org/manual/component-dsl.html#_using_component_dsl),我创建了以下代码:
package mygroupid.standalone;
import org.apache.camel.CamelContext;
import org.apache.camel.impl.DefaultCamelContext;
public class MyMain {
public static void main(String[] args) throws Exception {
CamelContext context = new DefaultCamelContext();
context.start();
ComponentsBuilderFactory.kafka()
.brokers("{{kafka.host}}:{{kafka.port}}")
.register(camelContext, "kafka");
context.close();
}
}
但是VSCode
中的Red Hat Language Server
告诉我:ComponentsBuilderFactory cannot be resolved
而且VSCode
中的quick fix
特性并不建议导入相应的库。
谁能给我指个方向?
我必须理解dependency injection
的概念才能做到这一点吗?
1条答案
按热度按时间rxztt3cl1#
As stated into the documentation that you are referring to,则需要将下一个依赖项添加到项目中:
其中,
x.x.x
与您使用的Camel版本相同如果您不使用maven、gradle等任何构建工具,您可以下载jar文件directly from the repository并将其添加到类路径中。
不要忘记按照此处所述正确管理您的属性占位符
{{kafka.host}}
和{{kafka.port}}
,或者将"{{kafka.host}}:{{kafka.port}}"
替换为您的目标代理主机名和端口。