首页 > 解决方案 > Apache Camel Kafka:如何在生产者配置中设置属性“delivery.request.ms”

问题描述

我正在尝试delivery.timeout.ms在生产者配置上设置属性,但是在 Camel Kafka 组件文档页面下找不到任何合适的(Camel 组件)选项。

我期待看到一个deliveryTimeoutMs可用的选项(就像 requestTimeoutMs 是 request.timeout.ms 一样),但它只是不存在。

根据camel-kafka api page,在所有版本中都没有可用的方法,那么Camel不支持这个选项吗?

标签: apache-kafkaapache-camel

解决方案


Producerdelivery.timeout.ms配置仅在最新版本的 Kafka 中添加到 KafkaProducer 配置中。据我了解有关Kafka Camel Options的文档,您需要在开头添加前缀“additionalProperties”,如下所示:

additionalProperties.delivery.timeout.ms

更改交付超时时,请务必遵循以下建议:“此配置的值应大于或等于和的总和request.timeout.mslinger.ms

Kafka Camel Options 的详细描述是

“为 kafka 消费者或 kafka 生产者设置附加属性,以防它们无法直接在骆驼配置上设置(例如:尚未反映在骆驼配置中的新 Kafka 属性),这些属性必须以附加属性作为前缀。”


推荐阅读