用kafka从MySQL导入数据到Postgres

Question

我有一个MySQL和Postgres之间的同步进程，只有一个表才能成功。

一旦我创建了一个新的表，并且在MySQL端添加了很少的记录，我就无法在Postgres中找到数据。你能帮帮我吗？

Answer 1

所以我知道现在已经很晚了，但我相信答案就在水槽上。

    "name": "jdbc-sink",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
        "tasks.max": "1",
        "topics": "customers",
        "connection.url": "jdbc:postgresql://postgres:5432/inventory?user=postgresuser&password=postgrespw",
        "transforms": "unwrap",
        "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
        "transforms.unwrap.drop.tombstones": "false",
        "auto.create": "true",
        "insert.mode": "upsert",
        "delete.enabled": "true",
        "pk.fields": "id",
        "pk.mode": "record_key"
    }
}

这里关注的主题是customers，它是mysql数据库中的表。无论您的桌子是什么名字，我都会加在顾客后面，让它来取。