Skip to content

Latest commit

 

History

History
10 lines (7 loc) · 640 Bytes

File metadata and controls

10 lines (7 loc) · 640 Bytes

Scala/Kafka/Avro examples

Example Kafka consumer and producer using Scala and Avro. The system is "Avro first" and relies on having Avro schema files stored in src/main/avro which are converted into Scala case classes using avrohugger and it's sbt plugin.

Generate the case classes using sbt avroScalaGenerateSpecific and then consume the classes like any scala case class. The code generation task should be automatically done as part of the test and compile tasks. Note IntelliJ's regular builder does not call the code generator.