Я создал исходную подписку на тему, у которой есть входное сообщение, подобное этому: {...

У меня есть кластер kafka, работающий локально, и тема с именем «my-topic», в которой я отправляю...

Мне трудно понять, как работает Windowing в Kafka Streams.Результаты не соответствуют тому, что я...

Я пытаюсь проверить ksql в режиме без головы.Я добавил запрос Create Table в файл запроса и...

У меня возникают проблемы при создании пользовательского UDAF в Ksql.Вариант использования - найти...

Я пытаюсь создать поток в Apache / KAFKA KSQL. Тема содержит (довольно сложный JSON) {...

При использовании платформы Confluent Open Source версии 4.1.0 я столкнулся со следующей проблемой:...

Я переписал данные в потоке и таблице. Я использую Confluent 4.1 1) Создать поток CREATE STREAM...

Я создаю повторно созданный поток CREATE STREAM details_stream_rekeyed2 as \ select CONCAT(IdSeq...

У меня есть два потока Kafka с ключами в String и значениями в формате Avro, которые я создал с...

Я новая пчела в ksql. Я просто играю с темами kafka для чтения в потоки, и это прекрасно работает....

Я пытаюсь присоединиться к следующему потоку Field | Type ---------------------------------------...

Я планирую использовать KSQL для потоковой обработки. У меня есть следующие требования. Как только...

ШАГ 1: Запустите производителя для создания образца данных ./bin/kafka-avro-console-producer \...

Я пытаюсь создать поток Kafka в KSQL поверх темы Kafka.У меня есть записи JSON, как показано ниже,...

У меня есть один steam и таблица в KSQL, как указано ниже: Имя потока: DEAL_STREAM Имя таблицы:...