Кажется, что kafka и ksql могли бы справиться с этим элегантно, но мне трудно найти его: может ли...
У меня есть запрос ksql, который объединяет два потока, выполняет оконную агрегацию,...
мы создали проект с функциями ibm и потоками событий в IBM Cloud. Теперь я пытаюсь подключить KSQL...
Я вижу в документации, что KSQL поддерживает формат Avro через реестр Confluent Schema.Но что, если...
Обычно я пытаюсь получить все столбцы, когда использую выражение group by в своем запросе. Создание...
Итак, я оцениваю Кафку.В нашем случае использования пришлось бы создавать новые темы, содержащие...
В database есть две таблицы.Например: макеты (Id, VenueId, Description) и Venues (Id, Adress,...
У меня есть данные темы kafka со следующей структурой: { property1:value1, property2:value2,...
создал поток, используя схему-реестр, без указания имени поля. См. Ниже CREATE STREAM sample_avro...
Привет! Я создал следующий поток со следующими значениями: "account_id VARCHAR, user_id VARCHAR,...
Привет! Я создал поток со следующими значениями из темы: "id VARCHAR, src_ip VARCHAR, message...
У меня есть система, которая сохраняет координаты (X, Y) в таблицу SQL.Затем у меня есть конечная...
Можно ли добавить строковое поле в таблицу / поток KSQL, которое будет содержать часть JSON...
как запустить ksql в среде Windows? мы установили слитную кафку в формате zip.мы не нашли файл...
У меня есть таблица с именем SUBSCRIPTIONS со следующими столбцами: KEY varchar, APPLICATION_ID...
Я создаю KTable из темы в формате значения JSON, производители темы также включают ключ для каждого...
При запуске KSQL с помощью файла ksql-server.properties с: sasl.jaas.config=org.apache.kafka.common
У меня есть потоковая тема в Json с 50 полями. Я пытаюсь создать другой поток с 1 полем, используя...
имеет имя темы json "customer-event" и пытается создать поток из приведенного ниже KSQL: create...
Есть ли способ преобразовать формат JSON, такой как: { "fruit": "apple",...
Как получить chunked-ответ от KSQL-сервера kafka в приложении весенней загрузки java? Когда я делаю...
ksql> CREATE TABLE HOPPING_TABLE AS SELECT ID, WINDOWSTART() AS WINSTART, COUNT(*) AS CNT FROM...
Я хочу отслеживать количество событий, произошедших за последние 30 дней. Поэтому я использовал...
Я использую Kafka KSQL REST API для выполнения запроса (/query), и внутри ответа я могу получить...
Мне было просто интересно, можно ли запустить KSQL на машине с Windows. Я скачал с https://www