Я запускаю следующий контейнер, используя образ докера для реестра Confluent Schema.Внутри...
Я запускаю Kafka и Zookeeper в Windows с помощью следующих команд: zookeeper-server-start.bat...
Допустим, я хочу написать модульный тест для показанного здесь примера: https://github
Итак, у меня установлен разъем Confluent Kafka JDBC.Сначала я запускаю реестр схемы, например
Я использую соединитель Debezium mongodb для потоковой передачи изменений из коллекции 30GB в mongo
Я установил confluent платформу на машине Ubuntu 16.04, и первоначально я настроил zookeeper, Kafka...
Я использую это Дебезиум-примеры source.json { "name": "inventory-connector",...
Я ищу, как читать авро-сообщения, которые имеют сложную структуру, из Kafka, используя потоковую...
Я запустил zookeeper и Kafka с помощью следующих команд: bin/zookeeper-server-start.sh...
В наших рабочих распределенных реквизитах мы имеем: value.converter=io.confluent.connect.avro
У нас есть Oracle Source, оттуда нужно получить данные, с ошибкой в формате Avro и Json. Файл...
Я пытаюсь установить поток данных, при котором издатель москитов будет отправлять данные брокеру...
При попытке запустить я получаю следующее: naren@tesla:~$ sudo su [sudo] password for naren:...
Я создал поток KSQL на основе схемы-реестра, выполнив эту запись .Соединитель JDBC Kafka обновляет...
Я пытаюсь использовать метку времени режима с MySQL, с ограниченными строками, так как размер моей...
Контекст Я кодировал пару небольших Kafka Connect разъемов.Один, который генерирует случайные...
Я использую Confluent JDBC Kafka для публикации сообщений в теме.Исходный соединитель будет...
Мы планируем выгрузить события с Kafka на S3 (например, с помощью kafka connect). Цель состоит в...
Реестр схем Confluent определил несколько уровней совместимости , которые богаче, чем проверки...
Я пытаюсь запустить реестр схемы и вижу следующее исключение. ERROR Server died unexpectedly: (io
Мы используем Kafka с Spring Cloud Stream, и нам нужно подключиться к реестру Confluent Schema в...
Шаги следуют Установленный / извлеченный слив 5.0.0.-2.11 Изменены свойства kafka-connect-jdbc /...
Я пытаюсь использовать сливной коннектор Kafka s3 , используя confluent-4.1.1 . s3 раковина...
Мой главный вопрос: почему происходит сбой реестра схемы? Периферийный вопрос: почему запускаются...
Я использую kafka connect (конфлюентное распределение) для подключения брокера mqtt к теме kafka...