spark streaming中报kafka的offset错误,如何解决

carolinecheng 发布于 2016/03/02 14:11
阅读 2K+
收藏 0
java.lang.AssertionError: assertion failed: Beginning offset 19309438 is after the ending offset 19270980 for topic mc_event_topic partition 28. You either provided an invalid fromOffset, or the Kafka topic has been damaged
at scala.Predef$.assert(Predef.scala:179)
加载中
0
whaon
whaon

同样遇到,请问解决了么

0
datadev_sh
datadev_sh

猜测kafka挂了

返回顶部
顶部