Я подключил Кафку к MySQL.Тема содержит данные в формате AVRO.Теперь я хочу преобразовать эти...
У нас есть производитель Kafka, который генерирует сообщения с очень высокой частотой для тем,...
Я могу успешно создавать и просматривать таблицы и потоки в KSQL, но они не отображаются как темы,...
Для данных, которые передаются из нашей системы заявок, мы пытаемся добиться следующего: Получите...
Я использую независимый ksql-server в 3-узлах, разговаривая с Kafka кластером из 3-х узлов. Создан...
Я хочу проверить мои сценарии KSQL, которые включают объединение потоковой таблицы на основе...
Я создал table в ksql из kafka topic.Выдвинул набор данных в тему и таблицы заполнены.Разместил...
У меня есть созданный скрипт KSQL для выполнения объединения потоковой таблицы.Помимо присоединения...
Я пытаюсь понять, есть ли у KSQL соответствующие характеристики производительности для нашего...
Я работаю с ksql уже довольно давно.Кластер кафки если из 3-х узлов.Я также использую udf, и все...
Я пытаюсь получить таблицу формата JSON для моего скрипта python, чтобы получить к нему доступ, и...
Ниже мой образец логина из темы кафки 2019-03-04T08:53:03.023Z "cd8cbe" 100.212.212.212 -...
Я создал поток ksql, используя create stream as select, и по какой-то причине запрос постоянного...
У меня есть тема кафки, которая получает события с: {timestamp, word, channel_id}. Мне нужно...
Этот вопрос относится к представлениям агрегации KSQL или технологии потоковой обработки.Когда мы...
Я использую локальный сервер KSQL (последняя версия Confluent Platform), пытаюсь подключиться к...
Я хотел бы спросить, могу ли я установить ключевое поле при создании таблицы? Я создал таблицу по...
нужна помощь.Мне нужно подтверждение того, как KSQL обрабатывает следующую ошибку: org.apache.kafka
Я начал работать с KSQL и вполне пережил опыт.Я пытаюсь работать с таблицей и потоком объединения и...
У меня есть тема Кафки, в которой около 3 миллионов записей. Я хочу выбрать одну запись из этого,...
В настоящее время я делаю POC потоков kafka, в котором я пытаюсь использовать kakfa как шину обмена...
Я новичок в ksql и уже давно пользуюсь mysql.Я хотел бы знать, есть ли в любом случае подзапросы в...
Я использую преобразование Avro Value, которое генерирует схему, подобную приведенной ниже (это...
Я пытаюсь реализовать управление окнами с помощью Kafka Streams, в котором мы получаем несколько...
Я пытаюсь объединить несколько событий из одного входного потока в одно выходное событие,...