一:数据倾斜,导致各个分区数据不均匀。最终导致kafka堵塞,数据消费不动。
第一步:先停掉kafka中,上游和下游的代码,对分配数据较多的分区进行重新分配。
https://cloud.tencent.com/developer/article/1755177
二:重新修改进入kafka的代码,防止进行后期继续发生数据倾斜。
可以设置一个新的列,根据这个列进行hash。
三:kafka默认自动存储在zk中。如果想存储到其他地方,例如mysql,需要手动进行修改。
猜你喜欢
- 21小时前你是我的优乐美(你是我的优乐美是什么歌)
- 16小时前金盾服装(金盾服装的标志是什么)
- 14小时前传说地下城怎么进(dnf传说在哪里做)
- 11小时前除夕夜守岁打一歇后语(除夕夜守岁打歇后语是什么)
- 11小时前460什么意思(460什么意思网络流行语)
- 8小时前当今中国四大家族的简单介绍
- 7小时前蜡烛的英文怎么读(蜡烛的英文怎么读语音)
- 7小时前中信客服电话(中信客服电话多少)
- 4小时前女t是什么意思(女生t p分别代表什么)
- 26分钟前耕地红线(耕地红线是多少亿亩)
网友评论
- 搜索
- 最新文章
- 热门文章