【flink】upsert kafka 数据展示实战

    CREATE DATABASE flink;
    USE flink;
    
    CREATE TABLE users (
      user_id BIGINT,
      user_name VARCHAR(1000),
      region VARCHAR(1000)
    );
    
    INSERT INTO users VALUES 
    (1, 'Timo', 'Berlin'),
    (2, 'Tom', 'Beijing'),
    (3, 'Apple', 'Beijing');
    
    

    CREATE TABLE users (
      user_id BIGINT,
      user_name STRING,
      region STRING
    ) WITH (
      'connector' = 'mysql-cdc',
      'hostna