spark+kafka报错java.lang.IllegalArgumentException: requirement failed: numRecords must not be negative

在执行kafka+spark程序时报错以下内容 ERROR JobScheduler: Error generating jobs for time 1588074000000 ms java.lang.IllegalArgumentException: requirement failed: numRecords must not be negative at scala.Predef$.req
相关文章
相关标签/搜索