Долгое время Кафка пытается избавиться от Zookeeper. Является ли использование Zookeeper устаревшим...
Мы установили центр управления документооборотом док-станции следующим образом: $ docker run -d \...
У меня проблема с KSQL: потеря данных во время потока обновлений (завершение потока запросов и...
Я хочу прочитать только 5000 записей в пакете через приемник jdbc, для которого я использовал batch
Я застрял с проблемой, связанной с потребителем Kafka, использующим библиотеку python...
У меня есть Dockerfile как таковой: FROM alpine:3.7 COPY confluent-5.3.0 confluent-5.3.0 COPY...
В кластере Kafka с определенными квотами для управления ресурсами брокера, которые используются...
Я использую сливное облако для обработки очереди, я уже создал кластер и тему, и все работает...
Я использую Confluent Platform 4.1.1 для передачи данных с sql-сервера в базу данных Oracle.Для...
У нас есть следующие требования к обработке потока. Source Stream -> transform(condition check -...
Я пишу простой продюсер, я просто хочу отправить необработанные данные в тему. по какой-то причине...
Мне нужно установить свойство 'group.id' в моем приложении KSQL. Я знаю, что это возможно в...
Я хочу использовать kafka-jms-client для замены моего текущего jms-брокера. Согласно документации...
Я реализовал UDF (пользовательскую функцию) для KSQL и настроил файл Maven pom.xml в соответствии с...
Я пытаюсь создать таблицу в потоке, используя двоичный файл ksql. Таблица создается и запускается,...
Как обрабатывать данные о поздних поступлениях соединителя источника в базу данных при мониторинге...
Как написать kafka avro сериализатор и десиализатор (т.е. используя io.confluent.kafka.serializers
Я попытался настроить 3-х узловый кластер kafka, используя сливные образы докера. https://hub
"представления ведут себя как форма постоянно обновляемого кэша"? Является ли это средним...
Я пытаюсь развернуть реестр Confluent Schema в нашей внутренней инфраструктуре AWS (ECS), чтобы он...
Я следую за настройкой инициализации образов докера Kafka Cluster, Zookeeper, Control-center,...
Я использую класс case, который имеет вложенные классы case, и Seq[Nested Case Classes] Проблема...