Flink读取Kafka数据，进行流处理APi操作（wordcount，分流，合流）一、pom文件二、将Kafka作为数据源，通过Flink进行词频统计 关键词：keyBy() reduce()三、通过split和select进行分流四、通过 connect map和union 进行合流
文章目录一、pom文件Finl跟Kafka结合的包將json轉換成對象的依賴剩下做需要的包，我在文章： https://blog.csdn.net/qq_44472134/article/details/104193662 中的《API操作》中提过，不知道的可以到这个网址上看看二、将Kafka作为数据源，通过Flink进行词频统计三、通过split和select进行分流，然后再存进Kafka一...
