Я создаю своего рода оболочку вокруг Flink SQL. Я создаю задание с набором определяемых пользователем операторов SQL с StreamTableEnvironment.sqlUpdate . Некоторые INSERT , некоторые CREATE . Еще я делаю несколько sqlQuery s. Прежде чем я...

У меня очень упрощенный вариант использования: я хочу использовать Apache Flink (1.11) для чтения данных из темы Kafka (назовем ее source_topic), подсчета в ней атрибута (называемого b) и записи результата в другую тему Kafka (result_topic ). Пока...