Windows環境下Flink消費Kafka實現熱詞統計

前言碎語 昨天博主寫了《windows環境下flink入門demo實例》實現了官方提供的最簡單的單詞計數功能，今天升級下，將數據源從socket流換成生產級的消息隊列kafka來完成一樣的單詞計數功能。本文實現的重點主要有兩個部分，一是kafka環境的搭建，二是如何使用官方提供的flink-connector-kafka_2.12來消費kafka消息，其他的邏輯部分和上文類似。 進入正題 本篇博文

>>阅读原文<<