Karamanoleff

Hi, I am facing similar issue when trying to use feeder for kafka messages. This is my example code: ``` val feeder = Array( Map("foo" -> "foo1", "bar" -> "bar1"),...