Project is not under development anymore
Reactive API for Log Collection & Processing on AWS, with focus on fetching logs from S3, Cloudwatch Logs and Kinesis. It currently supports writing to Kinesis, S3, Elasticsearch (incl AWS Elasticsearch Service), Influxdb & Graphite. It also has support for enriching functions like grok, compression etc. The processing pipeline is based on RxJava.
./gradlew clean build
Maven
<dependency>
<groupId>com.sonymobile</groupId>
<artifactId>lumbermill-{module}</artifactId>
<version>0.0.26</version>
</dependency>
Gradle
compile 'com.sonymobile:lumbermill-{module}:0.0.26'
All code inside the *.internal.* packages is considered private API and should not be relied upon at all. It can change at any time.