Kafka数据倾斜到某一个分区解决方案
Posted D-小白兔
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kafka数据倾斜到某一个分区解决方案相关的知识,希望对你有一定的参考价值。
1、原因:
我们使用Kafka时,某时需要消息消费是有序的,因此在生产者投递消息时,可能会指定分区,或者指定Key,此时可能会导致数据倾斜到某一个分区。
由于Kafka消费的特性,即一个消费组,那怕此时消费组有2个以上消费者,此时同一个主分区,只能被一个消费者消费,当生产消息大于消费消息时,就会出现单一分区数据倾斜。
2、解决:
根本原因,当指定分区,或者指定Key投递消息时。生产消息大于消费消息时,出现单一分区数据倾斜,此时消费端不能水平扩展。解决方案:
1、优化消费端的消费能力,如原来是200ms,优化后是50ms,当然可能无法优化;
2、二次消费用多个topic分摊分流消息,详细如下:
- 在消费端判定是哪个分区发生倾斜;
- 为这个发生倾斜的分区,建多个topic分摊分流,二次投递消费,水平扩展服务器;
- topic分摊分流,根据指定的Key,弄一个算法,以确保相同的Key落在同一个分区;
以上是关于Kafka数据倾斜到某一个分区解决方案的主要内容,如果未能解决你的问题,请参考以下文章