Member since
05-10-2017
3
Posts
0
Kudos Received
0
Solutions
05-10-2017
09:10 AM
Thanks for the very useful article. I am getting the below when trying to compile. constructor cannot be instantiated to expected type;
found : (T1, T2)
required: org.apache.kafka.clients.consumer.ConsumerRecord[String,Array[Byte]]
[ERROR] val rdd2 = rdd.map { case (k, v) => parseAVROToString(v) } Did anybody face this issue? Thanks.
... View more