我做了一个kafka的消息队列，在消费的时候是使用@Async+线程池多线程消费的，现在发现这个消息消费时一点都不快，而且线程开启的也很慢，哪位大神了解过这个问题，解决这个问题必有重谢
把消费线程固定一下，开启之后不要关闭消费线程了，30个分区的话最多开30个消费线程就行，开多了也只有最多30个线程拿到分区消费；
消费线程每次上线或者下线都会触发重平衡，导致消费者与分区的对应关系发生变动，重平衡是需要时间的，这应该就是你消费慢的根本原因
topic分区有几个，线程怎么配置的，你的数据处理逻辑是怎样的，业务处理与消费偏移量提交操作是不是串行的，topic是否有堆积