В нашем проекте мы рассматриваем возможность использования kakfa с потоковой передачей Spark, для PoC я использую версии 2.4.1 kafka и java8.
Как обрабатывать пропущенные данные при приеме тем Kafka?Как сохранить одитинг для того же?Какова практика индустрии больших данных в этом?Каким должен быть механизм восстановления, которому нужно следовать?Любые ссылки / видео примерно одинаковые?
Спасибо за ваши советы, комментарии и помощь