Простая классификация с потоками Кафки

Tim.G. спросил: 13 октября 2017 в 07:49 в: stream

В настоящее время я пытаюсь найти прямой и эффективный способ классификации записей с помощью Kafka Streams.
Все записи содержат по крайней мере свойство id и failed.
(id - это просто строка, а failed - логическое значение)

Идея состоит в том, чтобы в начале все входящие записи классифицировать как сообщение".
Как только одна из входящих записей имеет установленное поле с ошибками, это должно быть где-то" сохранено", и запись должна быть классифицирована как" ошибка".

Теперь каждая входящая запись с один и тот же id также должен быть классифицирован как "ошибка", независимо от того, установлено ли свойство failed.

Я думаю об использовании любого внутреннего состояния Магазин Kafka Streams (вместе с функцией интерактивного запроса) или внешняя база данных, которая будет запрашиваться каждый раз, когда поступает запись. Я думаю, что сам State Store Kafka звучит как более легкое решение.

Здесь это небольшой концептуальный очерк, надеюсь, помочь младшим Перейдите к этой проблеме.

Есть ли у кого-нибудь

>

>

>

> самый лучший Тим


0 ответов