Hi all, In case others find this useful I created a simple Samza job that uses Avro + the schema registry from the Confluent Platform. It's using the pending Pull Request to decode to Avro SpecificRecords.
Suggestions for improvement are also welcome. https://github.com/theduderog/hello-samza-confluent Cheers, Roger