我的目标是拥有一个数据流(KStream),其中包含Integer作为其ID,并将String作为其值,对于此示例,我们将在某个值中存储某人的名称.然后我还将创建一个使用GlobalKTable的查找表,它将术语作为其键(将与流的值匹配的术语)和布尔标志(表示任何与此术语匹配的名称是“垃圾邮件发送者”)作为值.

关于这方面的第一个问题是,是否可以将KStream与GlobalKTable一起加入正则表达式/模式匹配而不是严格匹配.

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

最佳答案 您可以使用
KStream#join(GlobalKTable)提供KeyValueMapper,将KStream中的项目映射到GlobalKTable中的项目.

在这个KeyValueMapper中,您可以通过正则表达式进行匹配,或者您也可以.