У меня есть объект JSON, у которого меньше полей. { "@timestamp":...
У меня есть простой KTABLE в KSQL, который называется DIMAGE Когда я запускаю следующий код {...
У нас есть Oracle Source, оттуда нужно получить данные, с ошибкой в формате Avro и Json. Файл...
У меня есть приложение весенней загрузки, которое подключено к кластеру kafka. Как я могу запустить...
Как я могу запросить список всех KTables и KStreams, которые есть в кластере Kafka? Что-то вроде...
Как объединить неравное количество потоков, содержащих разделы в KSQL, кроме увеличения раздела?...
Я использовал KSQL для создания потока и агрегированной таблицы из этого потока. {...
Есть ли в KSQL оператор LATERAL VIEW, который я не могу найти в документации?Или есть какой-нибудь...
Вариант использования Цель состоит в том, чтобы идентифицировать входящие события / строки, чтобы...
Есть ли способ создать поток из темы, определяющей, что вся запись должна рассматриваться как...
Я знаю, используя API-интерфейсы потребителей Kafka, мы можем получить смещение, соответствующее...
Я использую Kafka REST API, выданный из curl POST в ksql. Если я не использую LIMIT20, он зависает
Я борюсь с этим уже около недели, пытаясь получить простую (3 поля) отформатированную AVRO таблицу...
Использование KSQL (Confluent: Version: 5.0.1) Я могу нормально отбрасывать таблицу / поток...
Я делаю PoC, используя dotnet и ksql.https://github.com/pablocastilla/kafkiano/ Общая идея состоит...
Создан поток со следующим полем CREATE STREAM pageviews_original_string(view_time string, user_id...
Мы используем confluent платформу на Ubuntu.У нас есть простые данные JSON, отправляемые через...
На прошлой неделе я задал этот вопрос: KSQL: добавить несколько дочерних записей в родительскую...
Я хочу провести анализ поведения пользователя на событиях в Кафке.Может ли KSQL / Kafka Streams...
Я выполняю следующий запрос на ksql.но я хочу только последние 20 записей . SELECT MAX(ROWTIME)...
Я использовал ksql для вычисления некоторых метрик в реальном времени на основе живых событий
Я создал поток KSQL на основе схемы-реестра, выполнив эту запись .Соединитель JDBC Kafka обновляет...
Как я могу выполнить отношение 1 -> N в KSQL У меня есть одна таблица с bob_id в качестве...
Я пытаюсь использовать KSQL (как часть confluent-5.0.0) для создания одной записи из набора...
( Редактировать : небольшие правки для лучшего отражения намерения, но большие правки из-за...