Structured Streaming與Kafka的整合,實現不同json結構解耦

Structured Streaming與Kafka的整合,實現不同json結構解耦 問題:Structured Streaming從kafka的不同topic讀取數據,每個topic的value存取的數據格式是不同的。那麼怎麼使用一套模版代碼,分別對多個topic進行讀取數據。做到解耦呢? 思考:Structured Streaming讀取kafka的操作是一致的,只是對kafka的value值
相關文章
相關標籤/搜索