老师 topic2,topic3 要怎么读取?

来源:4-11 -Kafka实战之整合Flume和Kafka完成实时数据采集

慕函数0552834

2019-08-20

图片描述

写回答

2回答

慕函数0552834

提问者

2019-08-21

stream2
stream3
我的意思是不是要写这么多遍历?

0
1
Michael_PK
看这API的定义,可能需要,你可以创建几个topic自己测试下就能确定了。
2019-08-21
共1条回复

Michael_PK

2019-08-20

你代码中的messageStream.get(xxxx)  这里换下就可以了

0
0

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程