Я сталкиваюсь с WriteTimeOutException при записи в Cassandra с использованием...
Я хочу запустить kafka connect в распределенном режиме в моей настройке с 3 узлами.Но...
kafka-connect: kafka-connect-cassandra-1.2.1-2.1.0-all.jar Мои данные внутри Кассандры помечены...
В отношении этого примера пример с debezium У меня есть несколько тем с разными первичными ключами...
Я использую это примеры дебезия Я добавил "themes.regex": "CID1122. (. *)" в моем jdbc-sink.json...
Контекст: 1) Мы строим конвейер CDC (используя kafka & connect Framework) 2) Мы используем debezium...
Развернул Strimzi Kafka, Strimzi Zookeeper и Debezium mongodb и настроил Debezium mongodb, curl...
Я использую это Дебезиум-примеры source.json { "name": "inventory-connector",...
Я довольно новичок в Kafka и пытаюсь настроить и запустить простую систему соединения kafka с...
Я пытаюсь настроить тест для перемещения данных из MySQL в Elasticsearch. У меня есть докерская...
Использование: confluent-5.1.0 SINK Конфигурация: curl -X POST \ http://localhost:8083/connectors \...
Я использую сливной hdfs-коннектор 5.0.0 с kafka 2.0.0, и мне нужно использовать преобразование...
Наша команда занимается разработкой плагинов Kafka Connect Source Connector. Есть ли у вас...
Я пишу SinkConnector в Kafka Connect и решаю проблему. Этот разъем имеет такую конфигурацию: {...
Я перехожу на kafka в качестве брокера и debezium, чтобы получать данные (данные ETL) из всех...
1) У нас есть 3 узла kafka & kafka connect cluster 2) Мы запускаем kafka-connect на узлах kafka...
У нас есть требование выполнять массовую запись вasticsearch. Мы хотели бы знать, существует ли...
Я использую коннектор debezium для захвата изменений из базы данных MySQL и перемещения его в Kafka
Я создал преобразователь, который выполняет некоторые преобразования на ConnectRecord для...
У меня есть простая таблица базы данных в MySQL, которая имеет (id varchar(255), val varchar(255),
Запуск kafka connect в нашем docker-swarm со следующим файлом compose: cp-kafka-connect-node:...
Я работаю над решением, в котором у клиента уже есть iBM MQ, поэтому мне нужно интегрировать в него...
Пишу разъем для Kafka Connect. Я вижу ошибку при запуске разъема java.lang.IllegalAccessError:...
У нас возникают проблемы с обеспечением порядка, в котором сообщения из темы Kafka отправляются в...
Я бы хотел использовать версию kafka-connect с открытым исходным кодом вместо слитной, так как...