我试图delivery.timeout.ms
在“生产者配置”上设置属性,但是在Camel Kafka组件文档页面下找不到任何合适的(Camel Component)选项。
我期望看到一个deliveryTimeoutMs
可用的选项(就像requestTimeoutMs是request.timeout.ms一样),但是它不存在。
根据camel-kafka的api页面,在所有版本中都没有可用的方法,因此骆驼不支持此选项吗?
delivery.timeout.ms
仅在最新版本的Kafka中,生产者配置已添加到KafkaProducer配置中。据我了解有关Kafka Camel Options的文档,您将需要在开头添加前缀“ additionalProperties”,如下所示:
additionalProperties.delivery.timeout.ms
更改传递超时时,请确保遵循以下建议:“此配置的值应大于或等于request.timeout.ms
和linger.ms
。”
卡夫卡骆驼选项的详细描述是
“为无法直接在骆驼配置上设置(例如:骆驼配置中尚未反映的新Kafka属性)的情况下,为kafka使用者或kafka生产者设置其他属性,必须在这些属性前加上其他属性。”
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句