Made consumer config more flexible.

datanerds-io / verteiler

Meine dispatcher says there's something wrong mit deine Kabel. Java 8 BlockingQueue Kafka Consumer with automatically maintained offset.

Apache License 2.0

7 stars 3 forks source link

Made consumer config more flexible. #5

Closed jdrosensweig closed 8 years ago

jdrosensweig commented 8 years ago

Consumer configuration will now be provided a properties field with the typical kafka properties populated in it. Our version of the consumer will validate that auto commit is not enabled. But otherwise the client can configure the consumer with all other config fields.