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

Question

我想在kafka中做事件的用户行为分析。KSQL/Kafka Streams现在是否支持复杂事件处理？

Answer 1

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

您可以实现Kafka streams的低级Processor API，它允许您定义自己的转换器。

顺便说一句，您还可以将此链接到现有拓扑以及Kafka streams DSL。