spark streaming中报kafka的offset错误,如何解决
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)
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(2)
猜测kafka挂了
同样遇到,请问解决了么