New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Kafka group ID and index rollover interval changes #20

Open

kenangell wants to merge 6 commits into mariamhakobyan:master from kenangell:group-interval-changes

kenangell commented Apr 17, 2015

added configurable kafka consumer group id (if you need multiple consumers of the same data in kafka)
added setting to rollover the elastic search index by hour, day, or week (similar to logstash)
added configuration tests for changes
updated readme with settings.

Kenneth Angell added 6 commits

April 13, 2015 14:47


          Added consumer group config param.

81a9d4c


          * Updated maven dependencies with junit.

de6f640


          * Fixed scope of junit dependency

8c78062


          * added new time based index name resolver for rolling over elastic s…

e9b3805

…earch indexes.


          * add interval indexer to RiverConfig for use in ElasticSearchProducers

7bc5a04


          * update the readme with new configuration options.

deb1b65

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet