#mysql #apache-kafka #apache-kafka-connect #debezium
#mysql #apache-kafka #apache-kafka-connect #debezium
Вопрос:
Я использую Debezium и MySQL. В базе данных есть таблица, управляемая пролетом, и я хочу ее исключить. Я использовал приведенные ниже конфигурации:
name=IRS-Connector
connector.class=io.debezium.connector.mysql.MySqlConnector
database.hostname=mysql
database.port=3306
database.user=user
database.password=user
database.allowPublicKeyRetrieval=true
database.server.name=irs-conn-v1
database.include.list=decider
database.exclude.list=register
database.history.kafka.bootstrap.servers=localhost:9092
database.history.kafka.topic=schema-changes.decider
table.exclude.list=flyway_schema_history
Но когда я увижу тему irs-conn-v1.decider.был создан flyway_schema_history.
Ответ №1:
В соответствии с документом table.exclude.list опции:
Каждый идентификатор имеет вид
databaseName.tableName.
Поэтому вам нужно добавить databaseName :
table.exclude.list=decider.flyway_schema_history
Комментарии:
1. Здравствуйте, я попробовал, и это тоже не сработало.
2. Какая версия Debezium? Есть ли что-нибудь полезное в журналах?
3. Я использую Kafka с docker-compose и изображением landoop / kafka-lenses-dev, я пытался получить журналы, но в том, что я там нашел, нет ничего о Debezium.