Может ли KSQL / Kafka Streams поддерживать обработку сложных событий?

Question

Я хочу провести анализ поведения пользователя на событиях в Кафке.Может ли KSQL / Kafka Streams сейчас поддерживать обработку сложных событий?

Answer 1

Если «обработка сложных событий» в вашем вопросе означает реализацию сложной бизнес-логики, тогда ответ - да.

Вы можете реализовать низкоуровневый Процессорный API потоков Кафки, который позволяет вамопределить свои собственные трансформаторы.

Кстати, вы также можете связать это с существующей топологией вдоль боковых потоков Кафки DSL.