<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-streams-clients</artifactId>
</dependency>
public class RocketmqExample {
public static void main(String[] args) {
DataStreamSource dataStream = StreamBuilder.dataStream("test_namespace", "graph_pipeline");
dataStream
.fromFile("data.csv", false) //构建实时任务的数据源
.map(message -> message.split(",")) //构建实时任务处理的逻辑过程
.toPrint(1) //构建实时任务的输出
.start(); //启动实时任务
}
}打包
mvn -Prelease-all -DskipTests clean install -U运行
java -jar jarName mainClass