apache-kafka-streams - 如何在正则表达式/模式匹配上加入 KStream 和查找表 (GlobalKTable)？

Question

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

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

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

Answer 1

您可以使用 KStream#join(GlobalKTable) 提供KeyValueMapper映射您 KStream 中的项目到您的 GlobalKTable 中的项目.
在此 KeyValueMapper您可以通过正则表达式或随意匹配。