Я пытаюсь использовать kafka connect для чтения изменений в БД postgress. У меня Kafka работает в...
я пытаюсь достичь { "source": "NEWS", "metadata": {...
Я передаю события изменения базы данных из базы данных MySql в Kafka, используя коннектор Debezium...
Я пытаюсь запустить соединитель приемника JDBC со следующей конфигурацией: { "name":...
Я использую хранилище на основе JBoss для защиты конфиденциальных данных, таких как учетные данные...
Я пытаюсь удалить схему из полезной нагрузки, и вот конфигурации connector.properties...
Я новичок в Kafka Connect, но пытаюсь использовать его для загрузки некоторых данных в Postgres....
Я пытаюсь использовать конвертер Json в Kafka connect, но выдает ошибку ниже:...
Я пытаюсь добавить новый пользовательский Kafka Converter , который является модификацией...
У меня есть таблица, содержащая большое количество записей. Там есть столбец, определяющий тип...
Я пытаюсь использовать исходный соединитель Kafka Connect JDBC со следующими свойствами в режиме...
У меня есть два контейнера в моих тестах с использованием @Testcontainers с Junit5, Kafka и...
Я создал потребитель kafka, используя 'kafka-node', для файла события consumer
Я пытаюсь преобразовать все поля меток времени в строковый тип в формате yyyy-MM-dd HH:mm:ss. Чтобы...
Я настроил HDFS Kafka Connect для работы на Azure Datalake, однако я только что заметил, что ключи...
При запуске Kafka-Connect я видел много предупреждений 10:33:56.706 [DistributedHerder] WARN org
Я использую JdbcSinkConnector с postgres. Конфиг: { "name":"jdbc",...
Я использую соединитель JDBC для перемещения данных из MySQL в Kafka. Интересующие меня данные...
Я пытаюсь игнорировать плохие сообщения в коннекторе приемника с опцией errors.tolerance: all
Любой параметр в Kafka Connect, чтобы указать, с какого раздела специально читать сообщения.По сути...
если у меня уже работает Kafka в локальной сети, Kafka Connect - это просто конфигурация поверх...
Я пытаюсь создать исходный экземпляр Kafka-connect с помощью API отдыха. Я продолжаю получать...
Я достаточно много искал по этому вопросу, но, похоже, нет хорошего руководства по этому вопросу....
Я рассмотрел пример слияния потока потока кафки и обнаружения аномалий. В этом примере результат...
Я пытаюсь получить данные из Kafka с помощью коннектора debezium MongoDB, но получаю сообщение об...