Kafka org.apache.Kafka.commun.errors.Timeout某些记录的异常



在向Azure事件中心(启用kafka(生成记录时获取以下错误消息

Expiring 14 record(s) for eventhubname: 30125  ms has passed since batch creation plus linger time

Stack使用azure eventhub,Spring kafka

Kafka生产者配置中存在以下配置

props.put(ProducerConfig.RETRIES_CONFIG, "3");

想知道如果出现上述错误消息,卡夫卡生产商是否会重试3次

ProducerConfig.RETRIES_CONFIG->这种配置没有任何用处。默认重试设置为Integer.MAX_VALUE=2147483647。

生产者会在失败时自动重试。

请检查以下配置并进行相应调整。

  • linger.ms=0(尝试使用零,这将尽快发送批处理请求,非零值需要与其他参数一起进行更多调整(
  • buffer.memory->Producer在缓冲区中使用的最大内存,请尝试增加此值
  • 最大.block.ms->检查此值,这可能是timeoutException的原因。根据场景增加此值

最新更新