Add a simple streaming log input example in Scala