cclient/spark-streaming-kafka-offset-mysql

mysql 维护 kafka offset,支持追踪并回滚到某个'异常'时间点，重新消费

语言：Scala · GitHub 星标：4 · Fork：3

话题：mysql · offset · spark · spark-streaming

在 GitHub 上查看原仓库