stream 从kafka 接收数据

来源：7-18 需求三功能实现

qq_北辰元凰_0

2022-05-20

接收kafka 数据，有空行，这种情况一般是怎么造成的，和隐士转换有关系吗？图片描述

val logStream = stream.map(mapFunc = x => {
val splits = x.value()
.split("\t")
println(“start”)
println(x.value())
println(“end”)
(DateUtils.parseToHour(splits(0).trim), splits(1).toLong, splits(5).trim)
})

写回答

1回答

Michael_PK

2022-05-21

这里你的数据是不是就有空的呢？ split出来后，先做判空下

Michael_PK

qq_北辰元凰_0

哦哦哦，关键点就是数据判空不行，然后一行空数据，下面使用数组获取内容时就挂了

2022-05-21

共5条回复

Spark3实时处理-Streaming+StructuredStreaming实战

实战Spark3实时处理，掌握两套企业级处理方案

340 学习 · 238 问题

查看课程

相似问题

Flume和Kafka接收到数据后等待时间过长是什么原因呢？

回答 1

为什么代码不配置kafka的topic，也可以接收到这个topic里面的数据？

回答 1

kafka flume log4j

回答 1

云主机kafka对接SSS，有2个报错。

回答 2

kafka的数据，如何传递到结构化流？

回答 1

打开慕课网App查看更多内容