1、首先,溢出前,变的发送很慢,说明有资源枯竭。先监控系统,找到瓶颈点。(网络、cpu、内存、kafka阻塞慢)。
2、并发溢出,是多个方面引起的,首先,客户端发送消息到kafka之前,每个分区会缓存要发送的消息(分区数 x 缓存)。假设你的模拟消息制造者,消息即使没到kafka客户端缓存,那这部分消息在哪?也会占缓存。