Я перемещаю данные из Mongodb -> Elasticsearch, используя kafka connect. На данный момент...
В настоящее время я пытаюсь запустить соединитель приемника эластичного поиска в кластере...
У меня есть управляемый кластер kafka, работающий в облаке на Aiven (GCP). Я пытаюсь использовать...
Я использую kafka_2.12-2.3.1 на Ubuntu 18 с JDK 13. Пока все работает нормально, я заметил, что...
USE CASE Я читаю из уже созданной темы Kafka, в которой отдельный кластер создает некоторые ключи и...
Моя цель - развернуть коннекторы Kafka (приемник s3) с использованием контейнеров, поэтому важно...
Я пытаюсь подключиться к Kafka 3.0 с SSL, но сталкиваюсь с проблемой при загрузке хранилища ключей...
У меня есть Kafka Connector, использующий что-то вроде следующего: SELECT CAST ( id as VARCHAR) as...
Привет! Я использую debezium для захвата изменений в Mongo и отправки их в mysql. Я использую...
У меня работает раковина Kafka Connect. Я хотел бы контролировать отставание для этого. Я могу...
У меня настроен исходный соединитель, который извлекается из DB2 и использует режим отметки времени
Я добавил JDBC Source Connector, используя Kafka Connect, который извлекает данные из таблицы MySQL
Я запустил MySQL Debezium Kafka Connector ( Версия: 0.9.2.Final ) с одной таблицей в "table
Мы сталкиваемся с множеством неравномерно сбалансированных разъемов на нашей установке, начиная с...
Можно ли удалить вложенное поле с помощью SMT с подключением Kafka? Я знаю, что следующее прекрасно...
Мы собираемся использовать Kafka Connect JDBC Source Connector для получения данных из баз данных...
У нас есть микросервисная архитектура, и мы хотим публиковать события в темах Kafka для...
Я использую Kafka Connect в распределенном режиме. Странное поведение, которое я наблюдал несколько...
Это бизнес-требование, чтобы все сообщения, которые я использую в теме kafka, содержали печать...
Я использую Задачу Мойки Кафки для чтения записей из темы Кафки. Метод put () в SinkTask - это...
Я пытаюсь создать тему в Кафке. Когда я отправляю запрос на отправку сообщения в Kafka-connect для...
Я хотел бы использовать соединитель приемника s3 kafka connect для потоковой передачи данных нашей...
Можно ли генерировать сообщения JSON с помощью Debezium, а не Avro? У меня есть адаптер Debezium...
Я создаю Kafka Connector, который загружает список запрашиваемых элементов. Этот список элементов...
В настоящее время мы пытаемся использовать Debezium для регистрации изменений 4 таблиц в базе...