This code contains examples for a kafka producer / consumer in java and scala.
In the Java example we push a message in a kafka topic and then comsume it.
In the Scala example we generate some instances of a class Log and push them in a kafka topic and then calculate the number of logs grouped by date and level in a kafka consumer.