Я использую Confluent JDBC Kafka для публикации сообщений в теме.Исходный соединитель будет...

Я настроил Confluent Cloud с KSQL Server со следующей конфигурацией, как предложено, bootstrap

Как определить, когда KSQL полностью загрузил мои данные из темы Kafka в мою таблицу? ЦЕЛЬ:...

Я пытаюсь использовать KSQL для выполнения любой возможной обработки в течение определенного...

Я использую поток ksql и вычисляю события, приходящие каждые 5 минут.Вот мой запрос - select...

У меня проблемы с чтением сообщений из потока, который заполняется с помощью операции INSERT INTO...

Возникла проблема при вызове конечной точки KSQL Rest для выполнения запроса, мой запрос: выберите...

Я создаю одну тему kafka и создаю поток KSQL по этой теме, и я создаю таблицу в потоке для...

У меня есть поток данных в мои темы с сервера датчиков, который я не могу контролировать. В теме A...

Я пытаюсь создать данные в targetTopic1 на основе sourceTopic1 и sourceTopic2. Обе исходные темы...

Одно из имен полей в моем JSON - это «Агент пользователя». KSQL не нравится тире, когда я пытаюсь...

У меня работает простой брокер Kafka с темой raw_events. С помощью kafka-console-producer --topic...

Мне удалось найти несколько постов в блогах по тестам для обмена сообщениями Kafka (повсюду,...

Можно ли объединить более двух потоков / таблиц в KSQL? Пример: У меня есть три потока: CREATE...

У нас есть требование прослушивания нескольких тем и поиска определенного поля в событии каждой...

Я пытаюсь присоединиться к KStream: создан из темы, тема имеет значение JSON. Я повторно набираю...

У меня есть некоторая обработка сообщений с использованием потоков ksql, и я хотел бы добавить...

Допустим, у меня есть тема с данными прогноза температуры, как показано ниже: 2018-10-25,Melbourne...

У меня есть confluent-ksql-сервер, работающий на одном из узлов моего кластера.Можем ли мы...

Я пытаюсь построить конвейер данных от MySql до Ksql . Сценарий использования: источником данных...

У меня есть много тем, созданных без ключа, как я могу изменить их и добавить нужную? Мне нужно...

Я получаю сообщение об ошибке в confluent-5.0.0. ksql>CREATE TABLE order_per_hour AS SELECT...

У меня есть тема кафки по имени page_views и поток по имени pageviews.Теперь я хочу рассчитать...

Я работаю над confluent-4.1.1 с помощью ksql cli.Могу ли я создать поток для вложенного формата...

Я создал поток из Kafka, используя KSQL для темы Kafka, которая уже содержит некоторые сообщения.Но...