У меня есть бизнес-требование, где мне нужно 12-часовое оконное управление, и нужно запросить...
Я настроил соединение с базой данных и всю передачу данных по теме, потому что, когда я запускаю...
У меня есть поток данных, поступающий из разъема mongo CDC, но проблема в том, что ключ потока...
Я передаю длинную строку JSON String в тему kafka, например: { "glossary": {...
Здесь мой KSQL, используя WINDOW TUMBLING предложение: SELECT sale_date, region, SUM(total) FROM...
Возможно ли в KSQL вывести старые и новые значения из таблицы?Мы хотели бы использовать таблицу в...
Я застрял в проблеме, когда моя kafka работает на другом экземпляре, а мое приложение на другом...
Использование KSQL-CLI с темой kafka, сообщения которой являются объектами JSON.Я хочу извлечь поля...
Пожалуйста, найдите нижеприведенную проблему и подтвердите ее. Шаг-01: На основе условия соединения...
У меня есть пользовательский UDF с именем getCityStats (строковый город, двойное расстояние),...
Не могли бы вы дать мне знать, как обрабатывать нулевое значение в KSQL. Я пытался обработать 4...
У меня есть тема кафки, и каждое сообщение в теме имеет широту / долготу и метку времени события....
Я пишу авро сообщения в тему кафки, используя схему реестра.Затем создан поток на основе темы.Крик,...
Привет, у меня есть левое соединение потока Ksql (SEARCHREQUESTDTO) с таблицей Ksql (NGINX_TABLE)....
мы отправляем данные из DB2 (таблица-1) через CDC в темы Kafka (тема-1). нам нужно согласовать...
У меня есть тема Kafka, в которой есть данные о клиенте, покупке, продукте и т. Д. Я хочу создать...
Я бы хотел подключиться к своему собственному экземпляру Kafka, чтобы попробовать KSQL. Я скачал...
Я хочу получить метку времени запуска окна (здесь это 1530008520000) из команды...
Моя тема кафки состоит в передаче данных в этом формате (начиная с collectd ):...
Проблема: у меня есть таблица во внешней базе данных, содержащая события kafka, которые я опросил с...
У меня проблема с пробелами в именах при использовании EXTRACTJSONFIELD в KSQL Например: SELECT...
Я работаю над Kafka Streams.Я сталкиваюсь со следующими проблемами: Подробная информация о том, что...
В KSQL можно использовать EXTRACTJSONFIELD для вложенных структур, но я не понимаю, как обращаться...
Я использую confluent 4.1.1, я пробовал несколько агрегатных команд, но всегда возвращал NPE с...
Я пытаюсь поместить большое количество сообщений (350 МБ) в тему клиента (исходную тему) с таким...