我知道 酷酷同学 啥意思,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/
