如何通过具有动态更改规则的 kafka 流进行欺诈检测？

Question

我想在欺诈检测场景中使用 kafka 流。但是如何将它与动态更改的规则引擎（例如 Drools 规则）一起使用？我的想法是在一个 kafka 主题中填充流口水规则，将其视为 KTable，而将即将到来的客户数据存储在另一个 kafka 主题中，将其视为 KStream，然后将 KStream 与 KTable 加入，对吗？

Answer 1

也许你可以检查https://github.com/TouK/nussknacker？你会得到动态规则引擎，它有几个执行引擎（flink、embedded、kubernetes based），你也可以自己写。