[flink-SQL-API]??????kafka????json??????????????

[????]

????kafka??????????????????????????????????????????????????????sql??????????????


??????????????????????????????????????
??????????????????????"key.database,value.data.user_id,value.data.org_id"??????????????????????


????????????????????json????


{
        "key": {
                "database": "test",
                "table": "jhi_user_org",
                "pk.user_id": 9522636,
                "pk.org_id": 10065286
        },
        "value": {
                "database": "test",
                "table": "jhi_user_org",
                "type": "insert",
                "ts": 1576465904,
                "xid": 539057,
                "commit": true,
                "data": {
                        "user_id": 9522636,
                        "org_id": 10065286
                }
        },
        "metadata": {
                "offset": 760,
                "topic": "TEST_BINLOG_ALL",
                "partition": 0
        }
}