У нас есть KStream (взятый из темы Кафки), сообщения которого выглядят так:
Новые сообщения ..... (Key1, val11) (Key2, val20) (Key1, val10) ..... Старые сообщения
Мы конвертируем этот KStream в KTable, чтобы у нас было самое последнее значение для каждого ключа:
KEY VALUE
-------------
Key1 val11
Key2 val20
Как мне сделать то же самое в Spark, если предположить, что мое приложение Spark Streaming может использовать ту же тему Kafka?