spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From eugen.wintersber...@gmail.com
Subject Kafka structured straming - how to read headers
Date Thu, 03 Dec 2020 17:21:14 GMT
Hi folks,
  I am trying to read the message headers from a Kafka structured
stream which should be stored in a column named ``headers``. 
I try something like this:

val stream = sparkSession.readStream.format("kafka")......load()
stream.map(row => { 
 ...
 val headers = row.getAs[HeaderT]("headers")
....
})

My question is: what would be HeaderT?

Thanks in advance

 Eugen

Mime
View raw message