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.