在flink中使用jackson JSONKeyValueDeserializationSchema反序列化Kafka消息報錯解決
在做支付訂單寬表的場景,需要關聯的表比較多而且支付有可能要延遲很久,這種情況下不太適合使用Flink的表Join,想到的另外一種解決方案是消費多個Topic的數據,再根據訂單號進行keyBy,再在邏輯 ...
在做支付訂單寬表的場景,需要關聯的表比較多而且支付有可能要延遲很久,這種情況下不太適合使用Flink的表Join,想到的另外一種解決方案是消費多個Topic的數據,再根據訂單號進行keyBy,再在邏輯 ...