不敢

kafka没有相关的功能，只能靠你的消费者逻辑来实现（很复杂，还要增加队列和线程池，如果宕机数据全丢了等）。

另外，我想到变通的方式是：

• 暂停/恢复消费，查看kafka消费者Java客户端，搜索关键字「消费者流量控制」。
• 设置消费者拉取批次的数据量，通过设置不同的的比例，达到你的效果。

kafka没有相关的功能，只能靠你的消费者逻辑来实现（很复杂，还要增加队列和线程池，如果宕机数据全丢了等）。

另外，我想到变通的方式是：

• 暂停/恢复消费，查看kafka消费者Java客户端，搜索关键字「消费者流量控制」。
• 设置消费者拉取批次的数据量，通过设置不同的的比例，达到你的效果。

您看一下我另一个帖子 不知道您有没有遇到过类似的问题

看这个saveLo*这个方法单线程的情况下一秒能处理多少(主要的是你这方法的执行速度) 然后在批量消费合理分配线程
你现在这种方式消费数据量大的时候 kafka确实能做到秒ack(因为你异步处理) 压力全在线程池 如果线程池配置的是阻塞队列那就可以能丢数据，如果是非阻塞的 就不知道几百万下来 你内存能不能吃的住 同样的数据全部堆在内存队列安全系数很低

您有什么办法吗

你这并发一上来 你这线程池 吃的住？