在FlinkKafkaProducer获取sink表的建表key

Wed, 17 Mar 2021 19:40:39 -0700 

Hi！大家好。
目前有一个需求，需要获取Kafka 
sink表的所有建表字段，而且需要在FlinkKafkaProducer中进行操作，看了源码，没有找到获取这个信息的接口，大家有知道的吗？非常感谢！
例如：CREATE TABLE kafkaTable (

 user_id BIGINT,
 item_id BIGINT,
 category_id BIGINT,
 behavior STRING,
 ts TIMESTAMP(3)
) WITH (
 'connector' = 'kafka',
 'topic' = 'user_behavior',
 'properties.bootstrap.servers' = 'localhost:9092',
 'properties.group.id' = 'testGroup',
 'format' = 'csv',
 'scan.startup.mode' = 'earliest-offset'
) 
想获取到   user_id, item_id ，category_id ,behavior这四个字段。


| |
Jimmy Zhang
|
|
[email protected]
|
签名由网易邮箱大师定制

回复