我们要用 kafka 发送的数据很多,每天大概一亿条,每条大小在 2M 以内,其中,有的主题处理的文件比较小,大约几K,生产者发送速度很快; 但是有的主题里处理文件比较大,大于 1M,生产者发送速度很慢,导致文件大量积压在磁盘上,请问该怎么优化呢? 环境:kafka 2.3,jdk 1.8
因为kafka本身是不适合做这总单条消息很大的(默认1m,单条),所以调优的话,也只能加粗加大。
https://www.orchome.com/472
https://www.orchome.com/511
https://www.orchome.com/535
非常感谢
你的答案