flink问题集

CREATE TABLE t2 (
    id BIGINT,
    ts BIGINT,
    vc BIGINT
) WITH (
    'connector' = 'kafka',
    'topic' = 't2',
    'properties.bootstrap.servers' = 'hadoop001:9092',
    'properties.group.id' = 'test-t2',
    'scan.startup.mode' = 'group-offsets',
    'format' = 'json'
);