求助,关于kafka发送数据丢失的问题
发布网友
发布时间：2022-04-24 04:30
共1个回答
热心网友
时间：2023-08-18 13:57
procer的send方法是异步的，因此没有报错
将send的返回值Future定义，调用future.get()等待方法执行完毕的结果，这时候就报错了，
发现时因为num.partitioner=3，而在自定义Partitioner实现partition方式的时候，分区数使用了6，之前分区数是6，后来改回3了，int result = Math.abs(key.hashCode()) % numPartitioners的结果超过了0,1,2,因此报错了
