我知道 酷酷同学 啥意思,kafka 消息是key,value形式,当然这个key默认是null,他想在 select 语句里将 
kafka的key值读出来对吧。

我也在文档里找了,确实是没有相关文档说明



 
发件人: 酷酷的浑蛋
发送时间: 2021-01-15 16:35
收件人: [email protected]
主题: 回复: flink sql读kafka元数据问题
直接读topic,headers是空,我仅仅是想读key,不管topic是谁写入的
 
 
 
 
在2021年01月14日 16:03,酷酷的浑蛋<[email protected]> 写道:
你意思是说,topic不是flink写入的,用flink sql就不能读到key?
 
 
 
 
在2021年01月13日 15:18,JasonLee<[email protected]> 写道:
hi
 
你写入数据的时候设置 headers 了吗 没设置的话当然是空的了
 
 
 
-----
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复