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

Question

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

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

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

Answer 1

您可以使用KStream#join(GlobalKTable)提供KeyValueMapper将您中的项目映射KStream到 中的项目GlobalKTable。在这里，KeyValueMapper您可以通过正则表达式或任何您喜欢的方式进行匹配。