Kafka数据倾斜到某一个分区解决方案

Posted D-小白兔

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kafka数据倾斜到某一个分区解决方案相关的知识,希望对你有一定的参考价值。

1、原因:

我们使用Kafka时,某时需要消息消费是有序的,因此在生产者投递消息时,可能会指定分区,或者指定Key,此时可能会导致数据倾斜到某一个分区。

由于Kafka消费的特性,即一个消费组,那怕此时消费组有2个以上消费者,此时同一个主分区,只能被一个消费者消费,当生产消息大于消费消息时,就会出现单一分区数据倾斜。

2、解决:

根本原因,当指定分区,或者指定Key投递消息时。生产消息大于消费消息时,出现单一分区数据倾斜,此时消费端不能水平扩展。解决方案:

1、优化消费端的消费能力,如原来是200ms,优化后是50ms,当然可能无法优化;

2、二次消费用多个topic分摊分流消息,详细如下:

  1. 在消费端判定是哪个分区发生倾斜;
  2. 为这个发生倾斜的分区,建多个topic分摊分流,二次投递消费,水平扩展服务器;
  3. topic分摊分流,根据指定的Key,弄一个算法,以确保相同的Key落在同一个分区;

以上是关于Kafka数据倾斜到某一个分区解决方案的主要内容,如果未能解决你的问题,请参考以下文章

解决Maxwell发送Kafka消息数据倾斜问题

kafka kafka如何设置指定分区进行发送和消费

Flink对接Kafka常见问题与解决方案

FlinkFlink kafka producer 分区策略 (flink写入数据不均匀 与 数据写入 分区无数据 )

从0到1Flink的成长之路

走进大数据丨 MapReduce之数据倾斜