kafka线上问题整理和优化_kafka默认重试次数

一、前言

博主现在负责触达平台的建设，众所周知，对于4000万客户的推送来说，高流量的推送会导致系统负载更高，所以就会使用大量的消息队列来缓冲请求，达到削峰；但是由于网络抖动或者流量高峰期间可能会存在一些报错，现在记录下来并作为分享。

二、生产者问题整理

问题一：生产者写入超时

现象：

org.apache.kafka.common.errors.TimeoutException: Expiring 59 record(s) for mkt_push_statistics_filter-7: 30375 ms has passed since batch creation plus linger time
 
【[CAT异常告警]】
 
>**内容摘要**：<font color="warning">[异常告警]: [ 异常名称: TimeoutException  异常总量：1528.0 ]
 
[业务负责人: lili5 ] [告警间隔时间]5分钟</font>
 
>**告警节点**：ext-spring-jyyx-mkt-push-channel
 
>**告警级别**：<font color="warning">P0</font>
 
>**告警时间**：2021-05-13 20:40:04
 
>**故障ID**：4bca28cc0638bc3fc36a3db0ae9eac59
 
>**告警来源**：CAT
 
>**详情访问**：[Solaris告警平台](https://solaris.xxx.cn/solarisHistory/alert-detail?eventId=4bca28cc0638bc3fc36a3db0ae9eac5