报错:numRecords must not be negative

时间:2020-12-05 05:42:39

报错的原因:删除已经使用过的kafka topic,然后新建同名topic

解决方法:把topic名字换一下

(有其他更好的解决方法,可以不修改topic名)