报错的原因：删除已经使用过的kafka topic，然后新建同名topic
解决方法：把topic名字换一下
（有其他更好的解决方法，可以不修改topic名）
报错：numRecords must not be negative
Posted 右介
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了报错：numRecords must not be negative相关的知识，希望对你有一定的参考价值。
以上是关于报错：numRecords must not be negative的主要内容，如果未能解决你的问题，请参考以下文章