Тема MySQL+ Дебезиум + Кафка (тема не создана)

Question

Используя ниже свойства

name=mysql
connector.class=io.debezium.connector.mysql.MySqlConnector
database.hostname=localhost
database.port=3306
database.user=root
database.password=admin
database.server.id=42
database.server.name=mysql
database.history.kafka.topic=dbhistory.sys
database.history.kafka.bootstrap.servers=localhost:9092
include.schema.changes=true

Загрузка вроде

bin\windows\connect-standalone.bat config\connect-standalone.properties config\mysql.properties

созданные темы

dbhistory.sys,mysql

но при каких-либо изменениях в БД тема не создается. Я пробовал с монго + дебезиум. Работает нормально. Но не с MySQL.

Answer 1

Я думаю, вам нужно внести в белый список таблицу, для которой вы включили CDC, и хотите, чтобы Debezium создавал темы для этих таблиц, добавив эти свойства в файл Connector.properties:

1. data.dbname=Какую базу данных вы хотите указать?
2. table.whitelist=<schema.table1. схема.таблица2>