Я пытаюсь создать поток как избранный (CSAS), поток создается успешно, но когда я пытался отправить...

У меня проблема с созданием таблицы или потока в KSQL. Я сделал все, как показано в официальных...

Можно ли запросить KSQL KTable по ключу из отдельного приложения KStreams? Или, другими словами,...

происходит что-то странное, когда мы создаем сообщения AVRO через KSQL и пытаемся использовать их с...

Я искал документацию о том, где KSQL запрашивает хранилище и таблицы. Например, поскольку KSQL был...

У меня проблема с KSQL: потеря данных во время потока обновлений (завершение потока запросов и...

У меня есть поток delta чисел в теме кафки, который должен быть агрегирован особым образом,...

Я пытаюсь создать функцию UDF, которая принимает STRUCT в качестве параметра и возвращает структуру...

Я хотел бы отобразить ROWKEY результата запроса. К сожалению, он не сериализован, так как в...

У нас есть одна тема, которая называется igrationstatus , предположим, что мы разбиваем ее так,...

Я могу сказать, что я хочу начать чтение с «самого раннего», «самого позднего» или «нет», но мне...

Я пытаюсь обогатить некоторые данные о событиях с помощью KSQL (5.2.3) и Kafka (2.12-2.3.0). Left...

Я получаю предупреждение ksql ПРЕДУПРЕЖДЕНИЕ: время окончания окна было усечено до Long.MAX в...

Я создал поток, подобный этому: CREATE STREAM TEST1 WITH (KAFKA_TOPIC='TEST_1'...

Хотите вставить значения в столбец, имеющий тип ARRAY. Не нашел ссылки на это в справочном...

Я создаю производственную среду, в которой у меня будет Apache Kafka. Я хочу знать лучшую...

Я присоединяюсь к потоку KSQL и таблице KSQL. Оба сопоставлены с одним и тем же ключом. Но данные...

Я получаю неожиданные результаты от запроса KSQL к KTable, который сам определяется темой Kafka....

Я исследую некоторые вещи для работы, где мы должны доказать ценность Kafka и KSQL как части POC....

После долгих чтений в Интернете я наконец-то обратился к этому форуму. Моя задача состоит в том,...

У меня есть тема под названием клиенты, и я создал для нее поток CREATE STREAM customers_stream...

Я пытался изменить значение по умолчанию pk.fields для pk.mode: kafka. Тем не менее, я не смог...

Я пытаюсь получить доступ к KSQL CLI в первый раз на терминале Windows, но я получил ошибку: Unable...

Я разработчик мессенджеров и пытаюсь вычислить DAU / MAU, используя поток событий пользовательских...

Не могли бы вы предоставить мне пример кода в узле js, который выполняет запросы KSQL на Kafka?...