У меня есть создание приемника kafka connect, который конвертирует данные в другое хранилище;Я хочу...

Я пытаюсь использовать Debezium для подключения к базе данных mysql на моей локальной машине....

У меня есть несколько коннекторов и разделов Kafka, в которых размещены разные источники данных, но...

Я использую коннектор Confluent Kafka JDBC для получения данных из различных источников.Мне...

Как запустить несколько коннекторов Kafka в мире Kafka Connect в пределах одного распределенного...

Я использую MySQL-коннектор Debezium (0.7.5) и пытаюсь понять, каков наилучший подход, если я хочу...

Я использую этот соединитель https://www.confluent.io/connector/sap-hana-connector/ это моя...

У меня Confluent 5.0 на локальном компьютере, и я пытаюсь читать данные из Rest API с помощью Rest...

Я разрабатываю разъем для раковины Kafka самостоятельно.Мой десериализатор - JSONConverter.Однако,...

У меня есть рабочий кластер kafka-connect с 3 узлами в распределенном режиме, с работающим...

Как это исправить? org.apache.kafka.connect.errors.ConnectException: в этом работнике уже...

Kafka MirrorMaker - это базовый подход к отражению тем Kafka от исходного к целевым брокерам.К...

Я создал конвейер kafka для копирования таблицы sqlserver в s3 Во время слива я пытаюсь...

Я использую соединитель Debezium Postgres и обнаруживаю, что соединитель не захватывает столбцы...

Я хочу проиндексировать тему от kafka в формате avro до упругого поиска, но У меня проблемы с полем...

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

запуск Kafka Connect 4.1.1 на DC / OS с использованием пакета сообщества confluent. Как мы можем...

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

Создает ли Kafka Connect тему на лету, если она не существует (но предоставляется как место...

Я настроил kafka-connect-spooldir для использования файлов, содержащих объекты JSON, в соответствии...

Я выполняю несколько тестовых сценариев восстановления после сбоев для Kafka connect , процесс...

Я хочу получить данные из базы данных SQL Server, которая содержит данные, близкие к 5 ТБ.Я буду...

Я использую конвейер данных, так что я читаю данные из sql db в тему kafka через jdbc connect. Я...

Я получаю эту ошибку при попытке потоковой передачи таблицы RDS MySQL в Redshift: Ошибка...

У меня есть следующий кластер: Kafka -> какой-нибудь сборщик журналов -> Elasticsearch Моя проблема...