背景

今天在脉脉上面看到了一个帖子，比较有意思：

这个帖子的意思是：在使用Kafka的时候，我们已经设置了多个分区，如何去提升消费能力？如果使用线程池的方式去提升如何保证重启时消息不丢。这个帖子的意思是：在使用Kafka的时