周末多睡会

感谢！通过监控发现正在同步失效分区，还差50多个要同步

好的 谢谢

这个耗时你最好打点日志来看。
等待拉取时间是没用的，这个时间的意思是，当kafka里没有消息了，下一次尝试拉取的时间，如果kafka里一直有消息，就不会阻塞了。

大佬 如果产生阻塞,就是因为异步提交入库的逻辑比较耗时,导致线程池资源不够用对吧, 还有一点很奇怪的就是我提到的,在有消息挤压的情况下,会出来很多拉取消息为几条的情况~ 但是配置的有等待拉取时间,以及拉取的字节数和拉取消息的数量,但是一直找不到拉取很少几条数据的原因

默认配置情况下，1条消息处理时长最大是30秒（也就是提交一下offset），否则kafka则认为该消费者已经失连了，会重新平衡消费者，而这时你的消费者在提交，已经失效了。

1. 确认一下你的异步流程在丢消息进去的时候，是否有阻塞。因为即使你一次拿100条还是500条，你不阻塞的情况下，也会把队列很快加满的。
2. 多打一些日志，把你异步队列正在处理数量，每次提交offset的时间，都打印一下。

你这种写法很不安全，还是上面说的，kafka虽然你一个批次拉取的数量控制了，但是异步非阻塞的处理情况下，拉取的频繁了，效果是一样的。