This isn't supported yet, but there is on going work at spark-avro <https://github.com/databricks/spark-avro/issues/236> to enable this use case. Stay tuned.
On Fri, Feb 9, 2018 at 3:07 PM, Bram <theodorus.abra...@gmail.com> wrote: > Hi, > > I couldn't find any documentation about avro message deserialization using > pyspark structured streaming. My aim is using confluent schema registry to > get per topic schema then parse the avro messages with it. > > I found one but it was using DirectStream approach > https://stackoverflow.com/questions/30339636/spark- > python-avro-kafka-deserialiser > > Can anyone show me how? > > Thanks > > Regards, > > Abraham >
