Flink Connector Kafka 使用和剖析

在前面 3.6 節中介紹了 Flink 中的 Data Source 和 Data Sink,然後還講訴了自帶的一些 Source 和 Sink 的 Connector。本篇文章將講解一下用的最多的 Connector —— Kafka,帶大家利用 Kafka Connector 讀取 Kafka 數據,做一些計算操作後然後又通過 Kafka Connector 寫入到 kafka 消息隊列去。
相關文章
相關標籤/搜索