报错的原因：删除已经使用过的kafka topic，然后新建同名topic
解决方法：把topic名字换一下
（有其他更好的解决方法，可以不修改topic名）
报错：numRecords must not be negative
Posted 右介
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了报错：numRecords must not be negative相关的知识，希望对你有一定的参考价值。
以上是关于报错：numRecords must not be negative的主要内容，如果未能解决你的问题，请参考以下文章
报错解决——TypeError: LoadLibrary() argument 1 must be str, not None
python mysqldb 报错： ProgrammingError: must be real number, not str 解决
FlinkFlink 状态恢复报错 StateMigrationException For heap backendsthe new state serializer must not be
HDFS ha 格式化报错：a shared edits dir must not be specified if HA is not enabled.
FLinkAssigned key must not be null
presto查hive报错：end index must not be greater than size 问题分析和解决