我正在试着设置 delivery.timeout.ms 属性，但是我在camel-kafka组件文档页面下找不到任何合适的（camel组件）选项。
我本来想看到一个 deliveryTimeoutMs 选项是可用的（就像requesttimeoutms是request.timeout.ms一样），但它就是不存在。
根据camel-kafkaapi页面，在所有版本中都没有可用的方法，所以camel不支持这个选项吗？
我正在试着设置 delivery.timeout.ms 属性，但是我在camel-kafka组件文档页面下找不到任何合适的（camel组件）选项。
我本来想看到一个 deliveryTimeoutMs 选项是可用的（就像requesttimeoutms是request.timeout.ms一样），但它就是不存在。
根据camel-kafkaapi页面，在所有版本中都没有可用的方法，所以camel不支持这个选项吗？
2条答案
按热度按时间tyu7yeag1#
生产者配置
delivery.timeout.ms仅在kafka的最新版本中才添加到kafkaproducer配置中。据我所知，关于Kafka Camel 选项的文档需要在开头添加前缀“additionalproperties”，如下所示：更改传递超时时，请确保遵循以下建议：“此配置的值应大于或等于
request.timeout.ms以及linger.ms."关于Kafka Camel 选项的示例说明如下
为kafka使用者或kafka生产者设置其他属性，以防它们不能直接在camel配置上设置（例如：camel配置中尚未反映的新kafka属性），这些属性必须以additionalproperties作为前缀
5q4ezhmt2#
股票类
org.apache.camel.component.kafka.KafkaConfiguration不支持delivery.timeout.max. 但是您可以使用代理类 Package kafkanconfiguration示例来添加配置。我的建议是利用课堂org.springframework.cglib.proxy.MethodInterceptor，实现方法intercept()返回额外配置delivery.timeout.max