在《从0到1学习Flink》——DataSource介绍文章中，我给大家介绍了FlinkDataSource以及简短的介绍了一下自定义DataSource，这篇文章更详细的介绍下，并写一个demo出来让大家理解。
FlinkKafkasource准备工作我们先来看下Flink从Kafkatopic中获取数据的demo，首先你需要安装好了FLink和Kafka。
运行启动Flink、Zookepeer、Kafka，
好了，都启动了！
maven依赖1!--flinkjava--2dependency3groupIdorg.apache.flink/groupId4artifactIdflink-java/artifactId5version${flink.version}/version6scopeprovided/scope7/dependency8dependency9groupIdorg.apache.flink/groupId10artifactIdflink-streaming-java_${scala.binary.version}/artifactId11version${flink.version}/version12scopeprovided/scope13/dependency14!--日志--15dependency16groupIdorg.slf4j/groupId17artifactIdslf4j-log4j12/artifactId18version1.7.7/version19scoperuntime/scope20/dependency21dependency22groupIdlog4j/groupId23artifactIdlog4j/artifactId24version1.2.17/version25scoperuntime/scope26/dependency27!--flinkkafkaconnector--28dependency29groupIdorg.apache.flink/groupId30artifactIdflink-connector-kafka-0.11_${scala.binary.version}/artifactId31version${flink.version}/version32/dependency33!--alibabafastjson--34dependency35groupId白癜风哪里可以根治白癜风医院挂号