我们有一个kstream（来源于一个kafka主题），其中包含如下消息：
较新的消息…（key1，val11）（key2，val20）（key1，val10）…较旧的消息
我们将此kstream转换为ktable，以便为每个键提供最新值：

KEY     VALUE 
-------------
Key1    val11
Key2    val20

假设我的spark流媒体应用程序可以使用同一个Kafka主题，我如何在spark中做同样的事情？