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

Мне удалось успешно подключить соединитель GCS без включенного SASL или SSL.Когда я включаю SASL и...

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

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

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

При попытке запустить я получаю следующее: naren@tesla:~$ sudo su [sudo] password for naren:...

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

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

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

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

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

Я пытаюсь отправить данные мобильных приложений в брокер kafka.Я прочитал много постов и блогов,...

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

Я использую конфлюент Kafka-rest продукт, чтобы использовать записи из темы.Мое намерение состоит в...

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

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

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

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

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

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

Я столкнулся с некоторой проблемой в моей собственной настройке Kafka (слияния). Найдите...

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

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

Я использую Confluent JDBC Kafka для публикации сообщений в теме.Исходный соединитель будет...

Я создал источник и коннектор приемника для kafka connect Confluent 5.0, чтобы отправить две...