1、原因：
我们使用Kafka时，某时需要消息消费是有序的，因此在生产者投递消息时，可能会指定分区，或者指定Key，此时可能会导致数据倾斜到某一个分区。
由于Kafka消费的特性，即一个消费组，那怕此时消费组有2个以上消费者，此时同一个主分区，只能被一个消费者消费，当生产消息大于消费消息时，就会出现单一分区数据倾斜。
2、解决：
根本原因，当指定分区，或者指定Key投递消息时。生产消息大于消费消息时，出现单一分区数据倾斜，此时消费端不能水平扩展。解决方案：
1、优化消费端的消费能力，如原来是200ms，优化后是50ms，当然可能无法优化;文章来源：https://www.toymoban.com/news/detail-547172.html
2、二次消费用多个topic分摊分流消息，详细如下：文章来源地址https://www.toymoban.com/news/detail-547172.html
- 在消费端判定是哪个分区发生倾斜；
- 为这个发生倾斜的分区，建多个topic分摊分流，二次投递消费，水平扩展服务器；
- topic分摊分流，根据指定的Key，弄一个算法，以确保相同的Key落在同一个分区；
到了这里，关于Kafka数据倾斜到某一个分区解决方案的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
