Flink SQL自定义source解析weblog获取数据的topic信息

Mon, 18 Jan 2021 23:58:49 -0800 

之前用的spark做weblog解析，里面用topic中的partition+offset来做唯一key去重，示例如下：
String key =
MD5Utils.string2MD5(record.topic()+record.partition()+record.offset());

现在改用flink sql自定义source解析weblog，在解析weblog的时候，发现已经没有kafka相关信息，覆写的函数如下：
    @Override
    public DecodingFormat<DeserializationSchema&lt;RowData>>
createDecodingFormat(
            DynamicTableFactory.Context context, ReadableConfig
formatOptions) {}

请问，有办法在自定义source里面得到读取kafka的相关信息的办法没有？



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复