Я получил грязный код с debezium: "doulist_name": "2013...
Я использую debezium в своем java-приложении для получения изменений от Oracle 12c.База данных...
Я недавно включил binlogs в моей реплике для чтения, включив автоматическое резервное копирование...
Я запустил коннектор kafka, используя следующую команду: ./bin/connect-standalone...
Я создал движок Debezium Embedded для сбора данных изменений MySQL.Я хочу зафиксировать смещения,...
Я не могу заставить приемник Kafka Connect работать с таблицей, которой нет в общедоступной схеме....
Я использую CCC с потоком Кафки, который заполняется соединителем Postgres из Debezium. Я использую...
Я пытаюсь выполнить CDC с помощью debezium protobuf из Postgres 9.6, и в соответствии с инструкцией...
Я использую kafka 2.0 с kafka connect, работающим в распределенном режиме, и попытался настроить...
Я работаю над приложением, которое использует Debezium для потоковой передачи изменений из MongoDB...
Я новичок в кафке. Здесь я пытаюсь построить конвейер данных в реальном времени в Кафке. У меня...
Я использую PostgreSQL. В моей таблице числовой столбец определен так: "net_weight"...
Состояние задачи соединителя сбой с ошибкой: org.apache.kafka.connect.errors.ConnectException: java
Мне нужно написать клиент, который будет вставлять события в kafka. Мне нужно вставить несколько...
Я ищу соединитель debezium mysql для потоковой передачи записей CDC на kafka с ключом в виде строка...
Каждый раз, когда я перезапускаю контейнер debezium kafka-connect или развертываю другой экземпляр,...
Вот список плагинов моего коннектора: > curl localhost:8083/connector-plugins {...
Когда Debezium работает в качестве источника в kafka connect, и если какое-то время не происходит...