使用KSQL將轉換應用於Kafka資料流
阿新 • • 發佈:2018-12-12
我們正在瞭解更多關於KSQL的資訊,KSQL是Apache Kafka的SQL流引擎。一種查詢語言,可用於表達,然後將轉換應用於通過流Kafka流傳遞的資料。KSQL結合了查詢語言和Kafka資料流的強大功能,使用流行的平臺構建實時資料管道和流應用程式,提供更精確,更有意義的資料流。
使用KSQL到Kafka實時資料流的一些最常見的用例是:
將模式應用於資料。 過濾和遮蔽資料。 改變資料結構。 更改序列化格式。 豐富資料流。 統一多個數據流。 在資料流之上提供查詢語言層反映了我們如何移動資料的演變。查詢不僅僅是獲取儲存中的資料; 它可以很容易地與傳輸中的資料有關。允許我們在資料在企業中移動時查詢資料,然後還可能通過Web API使資料可用,使資料消費更精確,併為每個消費者量身定製。
我們正在努力更好地瞭解組織如何使Kafka工作,並使用KSQL來提供他們的主題流。我們的一些客戶正在將Streamdata.io Kafka聯結器用於我們服務的內部部署版本。我們希望確保我們的解決方案與他們使用Kafka的方式一致,幫助成為HTTP資料流分發的最後一英里,幫助增強Kafka的工業級容量,使用Server-Sent Events傳送的HTTP流(SSE),使用JSON PATCH提供增量更新。