Я пытаюсь выслушать тему, на которую я отправил сообщение, используя функцию подключения kafka к...
У меня есть Kafka Connect S3 Sink, пишущий записи в Amazon S3. Этот конкретный приемник пишет о 4k...
Итак, у меня установлен разъем Confluent Kafka JDBC.Сначала я запускаю реестр схемы, например
Когда я пытаюсь подключить Debezium к моей базе данных SQL Server после включения функции CDC, у...
Есть ли способ получить инкрементные данные из базы данных Oracle, используя пользовательский...
У меня есть приложение для разработки, где требуется подключить базу данных SQL Azure к Apache...
у нас есть проект Kafka Connect, в котором мы используем библиотеку , которая извлекает данные из...
В моей текущей конфигурации я использую: HdfsSinkConnector и класс разделителя:...
У меня возникло исключение, когда я запускаю свой соединитель kafka для эластичного поиска.Я...
Я пытаюсь опубликовать данные в kafka, читая данные из TeradataDB, используя Kafka-Connect...
Я пытаюсь подключить свою базу данных SQL Server к kafka на windows, я скачал файлы jar Debezium,...
ОШИБКА Обнаружена недопустимая ошибка документа при выполнении пакета 606 из 1 записей.Ошибка была...
Мы пытаемся скопировать данные из таблицы базы данных в Kafka, используя Confluent JDBC-Source...
Я использую соединитель Debezium mongodb для потоковой передачи изменений из коллекции 30GB в mongo
Мне нужна помощь по теме kafka, которую я хотел бы поместить в HDFS в формате паркет (с ежедневным...
Я создал пример данных опроса конвейера из MySQL и записал их в HDFS (в том числе в таблицу кустов)
Данные из исходной системы - abc@abc.com # kafka-avro-console-customer --bootstrap-server...
Мы используем Kafka Connectors (JDBC и другие) и настраиваем их с помощью REST API (используя curl...
У меня есть поле SQL DATETIME DT, которое я хочу передать в Kafka с помощью Avro.DT по местному...
Я пытаюсь индексировать сообщения в Elasticsearch, используя SMT только из Kafka Connect API. До...
есть ли какой-нибудь коннектор kafka, который читает из csv и конвертирует в Avro, прежде чем...
Я пытаюсь настроить kafka-разъем с помощью пользовательского преобразователя значений . Я использую...
У меня возникла следующая проблема: я работаю над потоковым приложением, которое использует Kafka и...
Я попытался создать базу данных с двумя таблицами в sqlite.Однажды в моей таблице есть столбец...
Я планирую использовать Kafka hdfs connect для перемещения сообщений из Kafka в hdfs.Глядя на это,...