小编Jus*_*tin的帖子

根据我的理解，分区和消费者被捆绑成 1:1 的关系，其中单个消费者处理分区。但是有没有这样一种在处理过程中重新分区的方法呢？我们目前正在尝试优化一个过程，在这个过程中，主题在一个组中被消费，但在某些情况下，某些消费者的数据处理需要更长的时间，而其他消费者已经空闲。它类似于数据清理，其中某个分区可能不再需要清理，而其他分区则需要模糊匹配，从而增加了消费者执行任务的复杂性。