1.首先是随便生产1000的同学(性别,年份)
2.先经过一个Flink处理之后,根据性别分成两个数据流,分别到不同topic的Kafka中
3.再对这个两个Kafka进行处理,根据2000年份前后进行分离
4.对四条数据流进行数量的统计
-
Notifications
You must be signed in to change notification settings - Fork 0
Kafka整合Flink学习项目
License
1144075799/KafkaToFlink
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
Kafka整合Flink学习项目
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published