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

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

Источник

1 ответ

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

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

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

Источник
Другие вопросы по тегам