Kafka Stream自动从新主题读取？

Question

有什么方法可以让我的Kafka Stream应用程序自动从新创建的主题中读取？

即使主题是在流应用程序已经运行时创建的？

类似于在主题名称中使用通配符，如下所示：

KStream<String, String> rawText = builder.stream("topic-input-*");

现在，我有多个客户端将数据（都使用相同的模式）发送到它们自己的主题，我的流应用程序从这些主题中读取数据。然后，我的应用程序进行一些转换，并将结果写入单个主题。

虽然所有的客户都可以写同一个主题，但一个没有偏见的客户也可以代表其他人写。所以我为每个客户创建了单独的主题。问题是，每当有新客户机出现时，我都会创建新主题并用脚本为其设置ACL，但这还不够。我还必须停止我的流应用程序，编辑代码，添加新主题，编译，打包，放到服务器上，然后再次运行！

Answer 1

Kafka Streams支持模式订阅：

builder.stream(Pattern.compile("topic-input-*"));

（我希望语法是正确的；从我的头顶上看不太确定……但重点是，您可以使用采用模式的方法的重载，而不是传入字符串。）