linkedin/sensei — pull request #50 by eshira (2012-08-09 16:32:43+00:00)
Title: Arbitrary Kafka configs for KafkaStreamDataProvider

Currently KafkaStreamDataProvider does not allow arbitrary Kafka options to be passed in. This means that custom gateways/data-providers that extend KafkaStreamDataProvider can't specify Kafka behavior (e.g. autooffset.reset).

This patch adds an optional argument to the constructor that allows you to pass in a java.util.Properties containing additional Kafka arguments.