apache-kafka - KSQL/Kafka Streams 可以支持复杂的事件处理吗？

Question

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

标签： apache-kafkaapache-kafka-streamscomplex-event-processingksqldb

Answer 1

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

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

顺便说一句，您还可以将其与 Kafka 流 DSL 旁边的现有拓扑链接。