Я пытался загрузить данные с SQL-сервера (с включенным отслеживанием изменений) в Kafka, чтобы их можно было использовать в одной или нескольких системах (отчеты, другие БД и т. Д.) Мне удалось настроить плагин подключения Kafka для сервера sql...

Можно ли генерировать сообщения JSON с помощью Debezium, а не Avro? У меня есть адаптер Debezium Kafka Connect, и я пытаюсь заставить его выводить сообщения JSON в тему Kafka. Это возможно?

Я использую встроенный Debezium, и мне кажется, что он отлично работает в единой среде разработки приложений. Однако у меня есть опасения по поводу того, что это будет в среде с несколькими узлами, где несколько экземпляров приложения будут пытаться...

Вопрос: Как мне настроить наблюдатель для просмотра потока Kafka-Connect в реальном времени по мере внесения изменений в базу данных? Я получаю Error while fetching metadata with correlation id 2 : {dbhistory.Test.Posts=LEADER_NOT_AVAILABLE} ....

сегменты перемещаются так быстро в нашем кластере Kafka, и это может быть связано с тем, что мы производим записи в кластере kafka с микросекундной меткой времени, а Kafka ожидает, что это будет в миллисекундах. Можно ли в коннекторе debezium...

У меня есть версия Postgres 10, и я пытаюсь настроить коннектор debezium с Kafka. Ниже приведены настройки, которые я сделал Set Wal_level = 'logical' создал слот репликации: SELECT * FROM pg_create_logical_replication_slot('slot_repl',...

Я начинаю играть с CDC и Kafka connect После бесчисленных часов попыток я понял логику Установите свойства Kafka Connect (bin/connect-standalone.sh) с информацией о вашем кластере. Установите файл конфигурации Kafka Connect...