как я могу интегрировать Kafka Connect с производителем Kafka в Java, чтобы я мог читать файл CSV в...

В hdfs для подключения Kafka у нас есть следующий класс SequenceFileWriter.java для записи...

В текущей инфраструктуре мы настроили ванильный apache Kafka, и мы начали регистрировать некоторые...

Я получаю следующую ошибку: "ОШИБКА WorkerSourceTask (id = test-mysql-dbc-source-0) Не удалось...

Я пытаюсь использовать записи из таблицы MySQL, которая содержит 3 столбца (Axis, Price, lastname)...

Я попытался подключиться к нескольким базам данных, включая MySQL и MSSQL, и у меня не было проблем

Я пытаюсь прочитать файл Avro, используя библиотеку python avro (python 2).Когда я использую...

Мы используем соединитель Kafka-Mqtt от команды Confluent. Есть ли способ опубликовать данные из...

У меня появляется json, как это: { "app" : "hw", "content" :...

В настоящее время мы используем несколько пользовательских подключаемых модулей для нашего...

Я играю с Кафкой на моем Mac и продолжаю получать ту же ошибку. Надеюсь на небольшое руководство,...

Я пытаюсь написать JSON с Kafka HDFS Sink. У меня есть следующие свойства (connect-standalone

Я пытаюсь настроить исходный соединитель для базы данных Adventureworks в postgres, таблица описана...

A с использованием коннектора Hbase StreamReactor Kafka с этой конфигурацией name=person-hbase...

Я пытаюсь создать таблицу кустов, извлекая схему из данных Avro, которые хранятся в s3. Данные...

Я хочу настроить Kafka Connect для записи максимально возможного количества записей в HDFS (мне...

Мы работаем над созданием приложения Kafka-connect, используя исходный соединитель JDBC в режиме...

У меня есть трехузловой кластер Confluent Kafka. На каждом узле запущены Zookeeper, Kafka Broker,...

У меня есть производитель, использующий kafka connect, который использует Confluent Kafka Connect...

Я использую следующий докер, создающий фрагмент: connect: image:...

Я получил это сообщение: WorkerSinkTask{id=hdfs-test-0} Sink task finished initialization and start...

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

Мы запускаем kafka connect для получения авро-данных из раздела kafka и сохраняем его в формате...

Использование документации слияния для kafka_cluster Я получил эту ошибку: Jul 03, 2018 4:20:41 PM...

У нас есть тема с сообщениями со скоростью 1msg в секунду с 3 разделами, и я использую разъем HDFS...