Мне нужно установить свойство 'group.id' в моем приложении KSQL. Я знаю, что это возможно в...
Мне нужно создать настройку Kafka, в которой в начале каждого дня все сообщения в теме должны быть...
1) Требуется ли ключ в потоке, где вы хотите выполнить функцию агрегирования.Я прочитал несколько...
Я реализовал UDF (пользовательскую функцию) для KSQL и настроил файл Maven pom.xml в соответствии с...
Я пытаюсь создать таблицу в потоке, используя двоичный файл ksql. Таблица создается и запускается,...
Запрос KSQL не возвращает ответ через API REST. ДАЖЕ Я использую ограничение CLAUSE.Моя тема...
Я пытаюсь внедрить скользящее среднее по объему в KSQL. Кафка в настоящее время принимает данные от...
Я пытаюсь создать таблицу ksql из существующей темы в kafka. Когда я запрашиваю таблицу, никакие...
Я установил RocksDB с помощью команды "sudo apt-get install librocksdb-dev". Как я могу...
У меня есть таблица ksql, содержащая менее 1000 записей.Когда я запускаю этот запрос select * from...
Я пытаюсь создать таблицу из темы с ключом объекта, но KSQL не распознает переменную. Есть ли...
Я искал пример, использующий Kafka Streams, о том, как сделать такого рода вещи, то есть объединить...
В операторе создания потока возникла проблема с пробелами в ключах. Например: CREATE STREAM test (...
Я пытаюсь сохранить результат запроса ksql (оконную таблицу) в базу данных, используя kafka connect
Я нахожусь в процессе изучения платформы Confluent (Kafka, Ksql и т. Д.).Я передаю данные в тему...
У меня есть данные в этом формате {"ROWTIME":1557825832927...
Я пытаюсь вставить данные из раздела Kafka в базу данных MongoDB с помощью Kafka-MongoDB-Connect....
Я создаю один главный поток со значением в виде массива.Я хотел бы получить поля массива в одно и...
есть способ заставить эту работу JSON DATA "Header": { "StoreID": 10225,...
Допустим, у меня есть 2 потока kafka (библиотека kafka-streams-scala, версия 2.2.0): val builder:...
Я пытаюсь получить данные из Object Array с помощью ksql. Любой, кто может мне помочь :) У меня...
У меня проблема с получением данных из темы Кафки. этот объект содержимого темы, я действительно не...
Я не могу извлечь данные из katable в выходной класс pojo Я попытался вызвать конечную точку покоя...
Учитывая процесс потоковой передачи, при котором входящие данные обогащаются производителем, а...
Я читаю данные с машины и транслирую их как JSON в тему кафки. Я хотел бы прочитать эту тему и...