网站首页
编程语言
数据库
系统相关
其他分享
编程问答
nextValue
2024-08-30
kafka指定key进行分区遇到的问题
问题描述:kafka在指定key进行分区的时候,若某一个分区异常,则发往这个分区的数据均会失败;没有指定key进行分区的便不会出现改问题。看一下producer的源码:publicintpartition(Stringtopic,Objectkey,byte[]keyBytes,Objectvalue,byte[]valueBytes,Clustercluster){