KSQL/Kfka Streams是否支持复杂事件处理

Question

我想对kafka中的事件进行用户行为分析。KSQL/Kfka Streams现在可以支持复杂事件处理吗？

Answer 1

如果问题中的"复杂事件处理"意味着实现复杂的业务逻辑，那么答案是肯定的。

您可以实现Kafka流的低级别处理器API，让您定义自己的转换器。

顺便说一句，你也可以把它沿着Kafka流DSL连接到现有的拓扑结构上。