Hi Armbrust,
It works well. Thanks. ---Original--- From: "Michael Armbrust"<[email protected]> Date: 2017/7/25 04:58:44 To: "??????????"<[email protected]>; Cc: "user"<[email protected]>; Subject: Re: how to convert the binary from kafak to srring pleaae There are end to end examples of using Kafka in in this blog:https://databricks.com/blog/2017/04/26/processing-data-in-apache-kafka-with-structured-streaming-in-apache-spark-2-2.html On Sun, Jul 23, 2017 at 7:44 PM, ?????????? <[email protected]> wrote: 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?
