Спасибо! Сработало

Добрый день. Задача про kafka streams: из нескольких топиков получаю сообщения и если сообщение удовлетворяет условию, его нужно записать в исходящий топик, но исходящий топик зависит от того в каком входящем топике находилось это сообщение. Подскажите как это реализовать в коде, т.к. пока мое приложение работает только с одним входящим и одним исходящим топиком. Входящие топики вроде как можно массивом передать, про исходящие совсем не понятно.

Не могу разобраться как в ksqlDB делать групировку ровно раз в минуту, что бы не изменения сыпало, а конечный результат раз в минуту скидвывало в какой нибудь топик. Про такое написано в доке, но как сделать почему-то не написали https://docs.ksqldb.io/en/latest/concepts/time-and-windows-in-ksqldb-queries/#window-final-results

ksqlDB offers a clean way to define this logic: after defining your windowed aggregation, you can suppress the intermediate results, emitting the final count for each user when the window is closed.

как вот это понять?

Добрый вечер. Парни, а никто cmak не юзал (ex kafka manager)?

Использую как вспомогательный интерфейс

Копай в сторону suppress

нашёл такое в kafka streams, а вот в ksqldb нет :(

Подскажи,  можно его как сервис запустить? Изгалялся всяко - падает

Windows или Kubernetes?

linux нода )

Штош

Systemd он умеет?

Просто возьми контейнер на основе этого например.
https://hub.docker.com/r/sheepkiller/kafka-manager/dockerfile

Либо если хочешь без контейнеров, то надо просто для systemd unit под него написать, он легко делается

В целом да. Можно запустить в докере. Про юнит согласен,  нчего сложного нет,  но... не взлетает. Причем на оф репе вообще ничего про возможность запуститься в фоне нет,  иные индусомануалы дичь какую-то предлагают(

Хм. Звучит очень странно.  Не запускается с помощью systemd, может если каких нибудь переменных окружений не хватило

И по юниту можно статус глянуть,  чего ему не хватило