IS
Я бы юзал второе, но зависит от ваших задач
Size: a a a
2021 June 22
IS
Схемма проста, констюмиш из топика пишеш через API (Stream API) в SF
IS
и радуешся
AT
Привет! А можно ли в kafka streams при использовании таблицы и оконных функций, брать как-то предыдущее значение? т.е. значение с прошлого окна? или можно как-то проще посчитать дельту между двумя окнами?
IS
С окнами не знаю. Но мы получали дельту таблицы через ksql. Материализовывали стрим A в таблицу A' и паралельно джойнили к копии стрима A эту таблицу A' на выходе получался стрим в котором помимо исходного занчения было ещё и предидущее значение сообщения с таким же ключём
AT
ksql это + еще кластер?
IS
по сути A -> JOIN A' -> A'
IS
Что ты имеешь в виду?
AT
это отдельное приложение под которое надо развертывать кластер, или это по сути те же стримы?
IS
ksql это SQL обертка вокруг kafka-streams в виде отдельного приложения (кластер возможен)
IS
всё что можно сделать на ksql можно и на kafka-streams
AT
тогда понятно, спасибо
AK
Привет! Ни у кого нет в последние дни проблем со входом на портал конфлюента? У меня перестало принимать мой логин, а при попытке сбросить пароль не доходит письмо
AK
@gamussa может сможешь сориентировать или куда-то направить?
AK
Да
AK
На почту или с сайта?
AK
Спасибо