2.45. Kafka
发送和接收来自 Apache Kafka 代理的信息。
2.45.1. 内部是什么
-
Kafka 组件, URI 语法:
kafka:topic
有关使用和配置详情,请参阅上述链接。
2.45.2. Maven 协调
在 code.quarkus.redhat.com 上使用此扩展创建一个新项目
或者将协调添加到现有项目中:
<dependency> <groupId>org.apache.camel.quarkus</groupId> <artifactId>camel-quarkus-kafka</artifactId> </dependency>
2.45.3. 使用方法
2.45.3.1. Quarkus Kafka Dev Services
Camel Quarkus Kafka 可以使用 Quarkus Kafka Dev 服务 来简化使用本地容器化 Kafka 代理的开发和测试。
在 dev 和 test 模式中默认启用 Kafka Dev Services。Camel Kafka 组件会自动配置,以便 brokers
组件选项被设置为指向本地容器化 Kafka 代理。这代表,无需自行配置这个选项。
可以使用配置属性 quarkus.kafka.devservices.enabled=false
来禁用此功能。
2.45.4. 其他 Camel Quarkus 配置
配置属性 | 类型 | 默认 |
---|---|---|
如果为 |
|
|
构建时修复的配置属性。所有其他配置属性可在运行时覆盖。