kafka数据积压问题如何解决 kafka怎么防止消息积压?
kafka怎么防止消息积压?卡夫卡,分区少了,消息积压就多了。合理增加卡夫卡分区的数量是关键。如果使用Spark stream和Kafka direct方法,KafkaRDD也可以重新分区以增加并行性
kafka怎么防止消息积压?
卡夫卡,分区少了,消息积压就多了。合理增加卡夫卡分区的数量是关键。如果使用Spark stream和Kafka direct方法,KafkaRDD也可以重新分区以增加并行性。此外,由于Kafka消息的key设置不合理,分区数据不均衡,也可能导致消息积压。您可以在Kafka produc
kafka数据积压问题如何解决?
我们可以这样做:首先,减少数据生产;其次,缩短数据存储周期,从默认的7天缩短到1天;最后,增加并发消费数据。