я тут загорелся идеей сделать скала-клиент для KSQL REST API
есть пока поддержка для моникса, и почти всех методов (создание стримов, таблиц, проверка состояний и выборка данных есть, только нескольких методов не хватает)
покритикуйте пожалуйста, если найдёте возможные ошибки
https://github.com/roomanidzee/kaesquella