如何在正则表达式/模式匹配上加入 KStream 和查找表（GlobalKTable）？

Question

我的目标是拥有一个数据流 (KStream)，其 ID 为 Integer，值为 String，在本例中，我们将在值中存储某人的姓名。然后我还将使用 GlobalKTable 创建一个查找表，该表将术语存储为其键（将与流的值匹配的术语）和一个布尔标志（表示与该术语匹配的任何名称都是“垃圾邮件发送者”）作为价值。

我在这方面的第一个问题是，是否可以将 KStream 与 GlobalKTable 加入正则表达式/模式匹配而不是严格匹配。

如果没有，我是否可以考虑更好的设计考虑来实现相同的目标？

Answer 1

您可以使用KStream#join(GlobalKTable) 提供一个KeyValueMapper，将KStream 中的项目映射到GlobalKTable 中的项目。 在这个KeyValueMapper 中，您可以通过正则表达式进行匹配，也可以随意匹配。