debezium应该只读取新的更改

idv4meu8  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(244)

即使我用的是快照。mode:schema_only,我得到了数据库的完整记录,而我只想要新的。我还有什么需要修改的吗?
这是我的源连接器的配置:

curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" \
 localhost:8083/connectors/ \
 -d '{    "name": "inventory-connector", 
          "config": { "connector.class":"io.debezium.connector.mysql.MySqlConnector",
                      "tasks.max": "1",
                      "snapshot.mode":"schema_only",
                      "database.hostname": "----", 
                      "database.port": "3306",
                      "database.user": "---",
                      "database.password": "----",
                      "database.server.id": "1",
                      "database.server.name": "data", 
                      "database.whitelist": "---",
                      "database.history.kafka.bootstrap.servers": "kafka:9092", 
                      "database.history.kafka.topic": "dbhistory.---"              
                    } 
      }'

暂无答案!

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

相关问题