Hi all
I want to change the binary from kafka to string. Would you like help me please?
val df = ss.readStream.format("kafka").option("kafka.bootstrap.server","xxxx")
.option("subscribe","xxxx")
.load
val value = df.select("value")
value.writeStream
.outputMode("append")
.format("console")
.start()
.awaitTermination()
Above code outputs result like:
+--------+
|value|
+---------+
|[61,61]|
+---------+
61 is character a receiced from kafka.
I want to print [a,a] or aa.
How should I do please?
