我在apachekafka中有一个消费服务器，它使用消息。
但是在poll循环中，我有一个耗时的过程（db访问）。
所以我的问题是：
如何确保我在给定的时间范围内阅读了消费者的所有消息？
我需要增加客户数量吗？