Error in setting up scala stream collector

It looks like your byteLimit is set to 10mb, could you try lowering this to 1mb?
byteLimit = 1000000

Seems like you might have the same issue as this post: Scala Stream Collector - java.net.SocketException: Broken pipe (Write failed)