在向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的原因。根据场景增加此值