Вручную зафиксируйте смещение в каталоге контрольных точек в структурированной потоковой передаче spark
#apache-spark #apache-kafka #apache-spark-sql #spark-streaming Вопрос: Я пишу потоковое приложение spark, читающее Кафку. Мой кафка получает по меньшей мере миллион событий в день. Мне приходится выполнять много вычислений для каждого получаемого…