Hi cheers,
Would you like write samw code please? I check the select method, i do not know how to cast it and how to set the value.deserialize. Thanks ---Original--- From: "Szuromi Tam??s"<[email protected]> Date: 2017/7/24 16:32:52 To: "??????????"<[email protected]>; Cc: "user"<[email protected]>; Subject: Re: how to convert the binary from kafak to srring pleaae 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 ?????????? <[email protected]>: 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?
