我们可以为生产者配置"delivery.timeout.ms"设置自定义值吗?



我正在使用 apache kafka 客户端 2.0.1,我正在查看类ProducerConfig,没有找到属性delivery.timeout.ms。这是否意味着,我们无法覆盖此生产者配置以设置自定义值?

此参数是通过 KIP-91 引入的。

该 KIP 是在 Kafka 2.1.0 版本中实现的。

发行于 2018年11月20日

Kafka 2.1.0 包含许多重要的新功能。这是一个 一些值得注意的变化摘要:

  • 爪哇 11 支持
  • 支持 Zstandard,可实现与 gzip 相当的压缩,具有更高的压缩率,尤其是解压缩速度 (KIP-110(
  • 避免活动使用者组的已提交偏移量过期 (KIP-211(
  • 在制作器中提供直观的用户超时 (KIP-91(

是时候升级:)了

最新更新