我正在使用一个inputTopic，并从中提取一个String（主题名称）列表。

List<String> Topics = {"Topic1", "Topic2", "Topic3"}

字符串
我需要为每个主题创建KStream以及它们的状态存储，其中应该只包含每个键的最后一个值。
这些主题（即，topic1、topic2和topic3已经存在，其中包含数百万条消息）。
如何创建这些（多个）流，异步地消耗每个主题的所有消息，并将它们写入outputTopic。
我对Kafka环境很陌生。