Flink与Kafka集成演示,类解析问题的解决方案
发布时间
阅读量：
阅读量
此处采用的是通过官方渠道提供的Maven命令构建的Flink 1.4.0版本的flink-quick-start项目，具体用于构建项目的指令如下：
mvn archetype:generate -DarchetypeGroupId=org.apache.flink -DarchetypeArtifactId=flink-quickstart-java -DarchetypeVersion=1.4.0
执行完成后，将获得一个基于Java语言的初始工程框架。
以下内容展示了一个Flink与Kafka进行连接的示例代码
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer010;
import org.apache.flink.streaming.util.serialization.SimpleStringSchema;
import org.apache.flin全部评论 (0)
还没有任何评论哟~