Я настроил коннектор debezium mysql, мне нужно добавить дополнительное поле в качестве имени...

Я установил конфлюэнтную Kafka на двух разных хостах и ​​пытаюсь заставить конфлюентный репликатор...

Я получаю данные JSON из темы Кафки.Мне нужно выгрузить эти данные в GCS (Google Cloud Storage) в...

Я использую Kafka Connect в Kubernetes (8-16 узлов, автоматическое масштабирование). Я определил...

В одном из моих вариантов использования я пытаюсь создать конвейер всякий раз, когда я отправлял...

В моем случае я создал соединитель JDBC kafka, извлек данные из таблицы оракулов и успешно отправил...

У меня есть asticsearch kafka-connect соединитель , использующий некоторые темы. Со следующей...

Согласно документации Кафки Конфигурации соединителя представляют собой простые сопоставления...

Я новичок в Apache Kafka. Я должен синхронизировать наших студентов и их регистрации. Всякий раз,...

Я использую io.confluent.connect.avro.AvroData.fromConnectData для преобразования сообщения перед...

Я сделал инкрементную синхронизацию данных с помощью kafka connect.Теперь я хочу добиться того же с...

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

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

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

У меня есть работающий экземпляр контейнера док-станции Landoop Fast Data Dev, который имеет...

Kafka Версия: 2.12-2.1.1 Я создал очень простой пример создания соединителя источника и приемника с...

Мы пытаемся записать значения из темы в базу данных postgres, используя Confluent JDBC Sink...

У меня есть сценарий использования, в котором я хотел бы сопоставить поле ключа исходной таблицы с...

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

Я новичок в Кафке. Я только что настроил один автономный разъем Kafka, ссылаясь на шаги из слияния...

Я столкнулся с аналогичной проблемой, упомянутой в https://github

Установлено: kafka_2.11-2.1.0 and zookeeper-3.4.13 Пробег: bin/zookeeper-server-start.sh...

У меня есть следующая конфигурация docker-compose.yml для моего коннектора Debezium: version:...

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

После создания объектов Connector и SourceTask в Kafka с Java я не могу понять, что можно сделать с...