Hi guys,

I'm using hive to store kafka topic metadata as follows::


CREATE TABLE orders (
        user_id    BIGINT,
        product    STRING,
        order_time TIMESTAMP(3),
        WATERMARK FOR order_time AS order_time - '5' SECONDS
) WITH (
        'connector.type'         = 'kafka',
        'connector.version'      = 'universal',
        'connector.topic'        = 'orders',
        'connector.startup-mode' = 'earliest-offset',
        'connector.properties.bootstrap.servers' = 'localhost:9092',
        'format.type' = 'json'
);

However, sometimes for incident handle, I have to set 'connector.startup-mode' 
to a specific timestamp, but I don't want to change the option setting in the 
hive table. Is there any way (api or ddl) to change  'connector.startup-mode'  
option in the flink jobs, but not impact the option stores in hive?


Best Wishes.

Reply via email to