“问题在这儿——Kafka重平衡时Consumer会暂停1-3秒,导致批处理数据积压。”
少年的声音温和中带着一丝铿锵的力量,让大厅内一下子静默下来。
此时他又紧接着说道:
没过多久,正在快速收录文件的江浔突然停了下来,他的目光停留在一段内容上——
‘Kafka分区再平衡导致流处理延迟……’
他沉思了片刻,然后起身走向白板写下:
“你觉得这位学弟多久能找出问题所在?”短发学姐碰了碰旁边的谭耀文,低声说道。
“最快也应该是明天早上,要知道我们这么多人也花了足足三个小时。”谭耀文如此说道。
短发学姐看着那个坐在边上快速翻阅文件的小学弟,笑道:
“要解决这个问题,可以用一致性哈希算法替代传统监听。”
说完,他直接在白板上写出了一大串代码,正是解决这个问题的可行性方案。
大厅中所有人怔怔的看着白板上的内容,足足十几秒后,才有人低头看了看手表。
#现行方案
(topics,
当他写完后,才发现大厅内几乎所有人都在盯着他,脸上带着或多或少的愕然。
“我倒觉得他可能下午下班之前,也有可能更快。”
谭耀文摇了摇头,不置可否。
其他人并没有怎么关注江浔,显然他们也和谭耀文的想法一样,今天之内他恐怕都没办法完成这个任务。

