Hi Armbrust,
It works well. Thanks. ---Original--- From: "Michael Armbrust"<mich...@databricks.com> Date: 2017/7/25 04:58:44 To: "??????????"<1427357...@qq.com>; Cc: "user"<user@spark.apache.org>; 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, ?????????? <1427357...@qq.com> 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?
