У меня есть созданный скрипт KSQL для выполнения объединения потоковой таблицы.Помимо присоединения, я выполняю фильтры на основе потока.Я развернул (интерактивно / без головы) и протестировал его. Можно установить критерии фильтра извне / свойства, чтобы можно было работать с другой конфигурацией.