我想在欺诈检测场景中使用kafka流。但如何将其与动态更改的规则引擎(例如 Drools 规则)一起使用？我的想法是在一个kafka主题中填充drools规则，将其视为KTable，同时将即将到来的客户数据存储在另一个kafka主题中，将其视为KStream，然后将KStream与KTable连接，对吗？
最佳答案
也许你可以检查https://github.com/TouK/nussknacker ？您将获得动态规则引擎，它有多个执行引擎(flink、嵌入式、基于kubernetes)，您也可以编写自己的。
关于drools - 如何使用动态变化的规则通过kafka流进行欺诈检测？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/51575906/