Kafka Stream簡單示例(三)---自定義Serde

本篇是在《Kafka Stream簡單示例(一)》 和《Kafka Stream簡單示例(二)—聚合 Aggregation–統計總和》基礎上成文的,建議先閱讀前兩篇,以便清楚上下文關係需求背景。 前面兩篇的代碼中,很多人看到最終的計算結果是通過Serdes.Long()或者 Serdes.String()像是寫入到topic中。於是有人問,能否將計算結果按照自定義格式寫入topic中?比如自定義
相關文章
相關標籤/搜索