190.2. 选项

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

布尔值

shutdownTimeout (common)

以毫秒为单位的超时，以正常等待使用者或制作者关闭和终止其 worker 线程。

30000

int