Hi,
You can cast it to string in a select or you can set the value.deserializer
parameter for kafka.
cheers,
2017-07-24 4:44 GMT+02:00 萝卜丝炒饭 <1427357...@qq.com>:
> 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?
>
