Kafka Consumer for Spark written in Scala for Kafka API 0.10: custom AVRO deserializer

Viewed 1254

I am upgrading my Spark Scala App Kafka API to v. 0.10. I used to create custom method for deserialization of the message which comes in byte string format.

I have realized there is a way to pass StringDeserializer or ByteArrayDeserializer as parameter to either key or value.

However,I can not find any information on how to create custom Avro schema deserializer so my kafkaStream can use it when I createDirectStream and consume data from Kafka.

is it possible?

1 Answers
Related