Я пытаюсь написать JSON с Kafka HDFS Sink. У меня есть следующие свойства (connect-standalone
Я пытаюсь настроить исходный соединитель для базы данных Adventureworks в postgres, таблица описана...
Я пытаюсь создать таблицу кустов, извлекая схему из данных Avro, которые хранятся в s3. Данные...
Я хочу настроить Kafka Connect для записи максимально возможного количества записей в HDFS (мне...
Мы работаем над созданием приложения Kafka-connect, используя исходный соединитель JDBC в режиме...
У меня есть трехузловой кластер Confluent Kafka. На каждом узле запущены Zookeeper, Kafka Broker,...
Я наблюдаю, что экземпляр потребителя не обнаружил ошибку во время регистрации потребителя, даже...
Я попробовал официальный пример schema-registry-confluent (потребитель / производитель) с моим...
Когда мы попытались прочитать kafka формата avro через тему kafka, при использовании...
У меня есть производитель, использующий kafka connect, который использует Confluent Kafka Connect...
Я использую следующий докер, создающий фрагмент: connect: image:...
Я получил это сообщение: WorkerSinkTask{id=hdfs-test-0} Sink task finished initialization and start...
зная, что мой kafka_cluster работает нормально, и я использую docker-compose Я положил внутрь...
В настоящее время, чтобы подключиться к базе данных MSSQSL, мне нужно создать локальную учетную...
Мы запускаем kafka connect для получения авро-данных из раздела kafka и сохраняем его в формате...
Использование документации слияния для kafka_cluster Я получил эту ошибку: Jul 03, 2018 4:20:41 PM...
У нас есть тема с сообщениями со скоростью 1msg в секунду с 3 разделами, и я использую разъем HDFS...
Я использую документацию confluent, но когда я добавляю разъем hdfs-sink, я получаю эту ошибку:...
Как настроить производителя и потребителя в Kafka REST Proxy? Если я использую kafka-clients.jar и...
Я следую учебнику @RobinMoffat "Simplest Useful .." для Kafka Connect и пытаюсь подключиться к моей...
Я пытаюсь запустить исходный соединитель JDBC Kafka со следующей конфигурацией: { "name":...
Мне любопытно узнать о преимуществах и недостатках Confluent's Kafka REST Proxy и производителя /...
Я пытаюсь настроить Sink Kafka Connect для Google Cloud PubSub Service. Использование следующей...
Выполнение простого эксперимента в командной строке после загрузки конфлуентного открытого...
Я пытаюсь получить доступ к БД SAP Advantage с помощью kafka connect, используя JDBC. Я использую...