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

Как часть POC, я пытаюсь вставить сообщения Avro с включенным реестром схемы из раздела Kafka...

Я использую слияние для реализации ETL в реальном времени.Мой источник данных - oracle, в каждой...

Я пытаюсь погрузить некоторые данные из темы Кафки в базу данных SQLite.Он проверяет таблицу и...

Я использую JDBC-коннектор для подключения к SAP и создания таблиц.Некоторые из них имеют @ в...

Я пытаюсь использовать Kafka Connect в локальном контейнере Docker (используя официальный образ...

Загрузка соединителя: { "name": "jdbc-source-test", "config": {...

Мое соединение HDFS-Sink: { "name":"hdfs-sink1", "config":{...

Я создал поток NiFi, который в конечном итоге публикует записи json в виде записей с...

Я использую распределенную установку kafka-connect. Я тестировал с одной установкой машины /...

Я подготовил производителя кафки, который помещает Список в тему кафки.Отлично работает на 1...

У нас есть коннектор Kafka Elastic Search для передачи данных в Elastic search (v 5.6.3 ). Я...

Я пытаюсь создать JDBC-коннектор для kafka с помощью команды curl.Пожалуйста, помогите мне...

Привет, я пытаюсь переместить данные в формате csv из kafka в hdfs, используя соединитель приемника...

Когда я передаю или транслирую две и три таблицы, я могу легко отобразить в Elasticsearch, но могу...

Ошибка, вызванная соединителем приемника JDBC: org.apache.kafka.connect.errors.DataException:...

Как включить метрики jmx для коннекторов Kafka?Я бегу подключен распределен. Я включил метрики jmx...

Я создал поток KSQL на основе схемы-реестра, выполнив эту запись .Соединитель JDBC Kafka обновляет...

Я пытаюсь использовать метку времени режима с MySQL, с ограниченными строками, так как размер моей...

Я using confluent.connect.cassandra.CassandraSinkConnector, для kafka подключите приемник cassandra

Я пытаюсь сгладить тему, прежде чем отправить ее на мою базу данных postgres, используя что-то...

Контекст Я кодировал пару небольших Kafka Connect разъемов.Один, который генерирует случайные...

Я пытаюсь перенести тематические данные из одного кластера Kafka в другой (оба на-linux).Для этого...

Я пытаюсь использовать метку времени режима с mysql, но она не создает никакой темы в моей очереди...

Я недавно обновился с версии 4.0.1 до версии 5.0.1.Версия bootstrap.server - Kafka 1.0.В моем...