у кого есть проблемы с выходным форматом коннектора File Sink? Интересно, почему я получаю такой...

При работе приложения Kafka Connect в распределенном режиме возникают случайные сбои JVM.Приложение...

Я использую Confluent.Kafka string kafkaEndpoint = "127.0.0.1:9092"; string kafkaTopic =...

Я использую kafka connect для получения исходных данных из DB2 в теме kafka, и я настраиваю...

Есть ли примеры конфигурации для CSV Source Connector, особенно связанные с генерацией схемы?Я не...

Используя образ kafka-lenses-dev , я столкнулся с проблемами при подключении Kafka к локальному...

Я пытаюсь написать отдельную Java-программу, использующую API-интерфейс kafka-jdbc-connect для...

Я пытаюсь написать преобразователь для нашего экземпляра Kafka Connect, который берет некоторые...

Когда я пытаюсь установить kafka-connect-spooldir с confluent-hub: confluent-hub install...

Настройка Таблица клиентов с полем CustomerID как nvarchar (50).(допустим, CustomerID = 100)...

мы сейчас находимся в процессе синхронизации данных из базы данных Oracle в новый экземпляр...

Я использую команду: # bin / connect-standalone.sh config / connect-standalone.properties config /...

Я пытаюсь вставить данные из Кафки в Teradata.Полезная нагрузка имеет некоторые нулевые значения, и...

Команда debezium kafka connect: docker run -it --rm --name connect -p 8083:8083 -e GROUP_ID=1 -e...

Я пишу соединитель Kafka, чтобы загрузить некоторые данные из нескольких источников на Github...

Я хочу использовать Kafka для публикации событий MSSQL CDC. Я использую контейнеры Docker для:...

Я использую Confluent platform 5.2.1 и исходный соединитель jdbc для чтения данных из таблицы MySql

Я пытаюсь CDC, используя Debezium и Kafka. Я зарегистрировал соединитель с 3 таблицами в свойстве...

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

Я запускаю развертывание kafka kubenetes helm, однако я не уверен в том, как установить...

{ transforms=SSNMask,IPMask,PhoneMask transforms.SSNMask.type=org.apache.kafka.connect.transforms

Я хочу передать данные из облачного приложения, которое будет публиковать журналы в разделах Kafka...

Я пытался использовать некоторые улучшения в Kafka Connect в версии 2.0.0, как указано в этом KIP...

Я пытаюсь сохранить результат запроса ksql (оконную таблицу) в базу данных, используя kafka connect

Может ли преобразователь значений Kafka connect (JSONConverter) использоваться для преобразования...