До сих пор у нас есть приложение для пакетной обработки, в котором мы просили источник сообщить нам, когда запускать наше приложение, на основе их входного сигнала, называемого «триггер».Поэтому, как только мы его получим, наше приложение начнет использовать данные до этого момента, рассматривая их как один пакет.
Но теперь мы хотим обработать это в нашем приложении независимо от исходного триггерного сообщения ввода.В новом потоковом приложении Spark мы хотим использовать и обрабатывать те же темы Kafka.