Я хочу прочитать только 5000 записей в пакете через приемник jdbc, для которого я использовал batch

Как обрабатывать данные о поздних поступлениях соединителя источника в базу данных при мониторинге...

Я хотел бы использовать событие из темы Кафки, добавить его в базу данных, выполнить несколько...

Я использую соединитель приемника HDFS Kafka для записи в HDFS из kafka, он работает нормально. Мои...

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

У меня есть данные в двух темах kafka из mysql с использованием debezium-connector-mysql-plugin

Используя преобразования одиночного сообщения (SMT), например, InsertField Transformation, можно...

Вариант использования Kafka: непрерывное чтение из Kafka (возможно, из потока), выполнение...

Я пытаюсь создать Kafka Data Ingestion в HBase через PySpark. В данный момент я пытаюсь вставить...

У меня есть простой сценарий для задания ETL: взять данные из темы Кафки и поместить их в таблицу...

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

Я использую kafka connect cassandra source connector 1.0 version.У меня есть столбец десятичного...

Я использую сливной коннектор для кафки и Google Cloud Storage (GCS). Я установил слияние с...

Я новичок в Confluent и пытаюсь использовать GCS в качестве приемника после экспорта данных из...

При публикации нового исходного соединителя с использованием Confluent: curl -X POST -H "Тип...

У нас есть случай использования, когда у нас есть устаревшая система, данные которой находятся в MS...