将新的debezium连接器添加到apachekafka重新启动快照

omqzjyyz  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(350)

我使用的是使用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"
}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题