190.2. 选项
Kafka 组件支持 8 个选项，它们如下所列。
| 名称 | 描述 | 默认 | 类型 |
|---|---|---|---|
| configuration (common) | 允许预先配置带有端点可重用的常用选项的 Kafka 组件。 | KafkaConfiguration | |
| brokers (common) | 要使用的 Kafka 代理的 URL。格式为 host1:port1,host2:port2，列表可以是代理子集或指向代理子集的 VIP。这个选项在 Kafka 文档中称为 bootstrap.servers。 | 字符串 | |
| workerPool (advanced) | 要使用共享自定义 worker 池在 kafka 服务器后继续路由 Exchange，请确认使用异步非阻塞处理从 KafkaProducer 发送到它的消息。如果使用这个选项，则必须处理线程池的生命周期，以便在需要时关闭池。 | ExecutorService | |
| useGlobalSslContext Parameters (security) | 启用使用全局 SSL 上下文参数。 | false | 布尔值 |
| breakOnFirstError (consumer) | 该选项控制在消费者处理交换时所发生的情况，它会失败。如果 选项为 false，则使用者将继续进行下一个消息并进行处理。如果 选项为 true，则使用者将中断，并且会重新查找导致失败的消息偏移，然后重新尝试处理此消息。但是，如果其绑定每次都失败，则可能导致完全无法处理同一消息，例如投毒消息。因此，建议通过使用 Camel 的错误处理程序来处理该示例。 | false | 布尔值 |
| allowManualCommit (consumer) | 是否允许通过 KafkaManualCommit 进行手动提交。如果启用了这个选项，则 KafkaManualCommit 实例存储在 Exchange message 标头上，这允许最终用户访问这个 API，并通过 Kafka consumer 执行手动偏移提交。 | false | 布尔值 |
| kafkaManualCommit Factory (consumer) | 创建 KafkaManualCommit 实例使用的工厂。这样，在进行手动提交时，可以插入一个自定义 KafkaManualCommit 实例来创建自定义 KafkaManualCommit 实例。 | KafkaManualCommit Factory | |
| resolveProperty Placeholders (advanced) | 启动时，组件是否应自行解析属性占位符。只有 String 类型的属性才能使用属性占位符。 | true | 布尔值 |
Kafka 端点使用 URI 语法配置：
kafka:topic
使用以下路径和查询参数：
190.2.1. 路径名(1 参数)：
| 名称 | 描述 | 默认 | 类型 |
|---|---|---|---|
| topic | 要使用的主题的 必需 名称。在使用者上，您可以使用逗号分隔多个主题。制作者只能发送消息到单个主题。 | 字符串 |
