1 原因是：
多个相同的Spark Streaming同时消费同一个topic，导致的offset问题。关掉多余的任务，就ok了。
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。
猜您在找
spark streaming连接kafka引发"partition.assignment.strategy"异常处理
Spark streaming消费Kafka的正确姿势
Spark——Structured Streaming 监控Kafka消费进度
spark streaming消费kafka数据写入hdfs避免文件覆盖方案(java版)
Spark Streaming消费Kafka Direct方式数据零丢失实现
spark streaming 消费 kafka入门采坑解决过程
spark streaming kafka消费多个topic时不执行的问题
Spark Streaming消费Kafka Direct方式数据零丢失实现
Spark Streaming + Kafka java.lang.IllegalArgumentException: requirement failed: numRecords must not be negative
spark streaming从指定offset处消费Kafka数据