job.scala

val sRule = implicitly[RuleLike[AvroValue, String]]
val drRule = implicitly[RuleLike[AvroValue, DefectResult]]
def kTransform(g: GenericRecord) = RecordTransformations.convert(g, sRule)
def vTransform(g: GenericRecord) = RecordTransformations.convert(g, drRule)

val defectResults: DStream[(String, DefectResult)] = KafkaCommons.read[String, DefectResult](consumerConfig, ssc)(kTransform, vTransform)

object RecordTransformations {
  def convert[T](genericRecord: GenericRecord, rule: RuleLike[AvroValue, T]): VA[T] = {
    Avro.fromAvro[T](Avro.wrap(genericRecord))(rule)
  }
}