Apache Camel Kafka:如何在Producer配置上设置属性“ delivery.request.ms”

伊沃

我试图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.mslinger.ms。”

卡夫卡骆驼选项的详细描述是

“为无法直接在骆驼配置上设置(例如:骆驼配置中尚未反映的新Kafka属性)的情况下,为kafka使用者或kafka生产者设置其他属性,必须这些属性前加上其他属性。”

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

JAXRS API上的Apache Camel?

来自分类Dev

如何使Apache Camel Routes更快?

来自分类Dev

如何使Apache Camel Routes更快?

来自分类Dev

Apache Camel:设置属性和获取方法

来自分类Dev

使用 Apache Camel + Jetty 组件的 GET-Request

来自分类Dev

如何在Apache Camel中设置MQGet CodedCharSetID

来自分类Dev

通过Apache Camel从Kafka消费Avro消息

来自分类Dev

Apache Camel:exchange.getException()与CamelExceptionCaught属性

来自分类Dev

Linux 上的 Apache Camel 文件 IO

来自分类Dev

如何在 apache camel DSL 或骆驼处理器中设置额外的身份验证属性?

来自分类Dev

Apache camel,RabbitMQ如何发送消息/对象

来自分类Dev

如何使用Apache Camel监视文件更改?

来自分类Dev

Apache Camel EIP路由-如何停止split()

来自分类Dev

如何使用Apache Camel聚合CSV行?

来自分类Dev

如何从Apache Camel中的curl获得结果?

来自分类Dev

如何处理Apache Camel NoRouteToHostException异常?

来自分类Dev

如何使用 Apache Camel 交换消息?

来自分类Dev

如何使用 Camel Apache Timer 组件

来自分类Dev

Apache Camel:从其部分设置父交换的属性(拆分)

来自分类Dev

如何配置Apache Camel Quartz端点以使用JDBCJobStore

来自分类Dev

Apache Camel Producer消费者术语难题

来自分类Dev

Apache Camel:Producer模板未添加到SEDA端点

来自分类Dev

如何在Apache Camel中测试多个RouteBuilder

来自分类Dev

如何在Apache Camel中模拟cxfbean调用?

来自分类Dev

如何在Apache Camel中测试多个RouteBuilder

来自分类Dev

Apache CXF和Apache Camel

来自分类Dev

Apache Camel JDBC插入

来自分类Dev

Apache Camel路由性能

来自分类Dev

迁移Apache Camel端点