我使用的是使用ApacheKafka2.4的debezium/kafka(v1.0)。
此外,我还部署了一个debeziummysql连接器,用于监视一些配置为在开始时获取快照的表,目前一切正常。
过了一段时间,我需要开始监视其他表,所以我创建了另一个连接器,这次没有快照,因为不需要。
这将导致第一个连接器再次开始拍摄快照。
这是预期的行为吗?
在没有其他连接器的情况下,如何开始监视新表并再次获取快照?
提前谢谢。
添加的编辑配置:
第一个连接器
{
"name": "orion_connector_con_snapshot_prod_v1",
"connector.class": "io.debezium.connector.mysql.MySqlConnector",
"tasks.max": "1",
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"database.hostname": "my_host",
"database.port": "3306",
"database.user": "my_db",
"database.password": "*********************",
"database.server.name": "orion_kafka",
"database.history.kafka.bootstrap.servers": "kafka:9092",
"database.history.kafka.topic": "history_orion",
"database.history.skip.unparseable.ddl": "true",
"database.history.store.only.monitored.tables.ddl": "true",
"table.whitelist": "orion.orion_CABA_datosbasicos,orion.orion_Cordon1_datosbasicos,orion.orion_Cordon2_datosbasicos,orion.orion_Cordon3_datosbasicos,orion.orion_Cordon4_datosbasicos",
"snapshot.mode": "when_needed",
"snapshot.locking.mode": "none"
}
引发问题的第二个连接器
{
"name": "nexo_impactos_connector_sin_snapshot_v1",
"connector.class": "io.debezium.connector.mysql.MySqlConnector",
"tasks.max": "1",
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"database.hostname": "my_host",
"database.port": "3306",
"database.user": "my_db",
"database.password": "*********************",
"database.server.name": "nexo_kafka",
"database.history.kafka.bootstrap.servers": "kafka:9092",
"database.history.kafka.topic": "nexo_impactos",
"database.history.skip.unparseable.ddl": "true",
"database.history.store.only.monitored.tables.ddl": "true",
"table.whitelist": "dashboard.nexo_impactos",
"snapshot.mode": "schema_only",
"snapshot.locking.mode": "none"
}
暂无答案!
目前还没有任何答案,快来回答吧!