SUMOK-16 Configuration for CloudWatch logs

Author: Juan Pablo Diaz-Vaz

build.xml

@@ -31,6 +31,7 @@
         <get src= "http://central.maven.org/maven2/com/google/protobuf/protobuf-java/2.6.1/protobuf-java-2.6.1.jar" dest="${external.dir}/lib" usetimestamp="true" verbose="true"/>
         <get src= "http://central.maven.org/maven2/commons-lang/commons-lang/2.6/commons-lang-2.6.jar" dest="${external.dir}/lib" usetimestamp="true" verbose="true"/>
         <get src= "http://central.maven.org/maven2/org/apache/lucene/lucene-core/4.8.1/lucene-core-4.8.1.jar" dest="${external.dir}/lib" usetimestamp="true" verbose="true"/>
+    	<get src= "http://central.maven.org/maven2/commons-codec/commons-codec/1.10/commons-codec-1.10.jar" dest="${external.dir}/lib" usetimestamp="true" verbose="true"/>
 
         <get src= "https://hamcrest.googlecode.com/files/hamcrest-core-1.3.jar" dest="${external.dir}/lib" usetimestamp="true" verbose="true"/>
 

src/main/java/com/mcplusa/kinesis/StreamSource.java

@@ -125,7 +125,7 @@ protected void processInputStream(InputStream inputStream, int iteration) throws
                 PutRecordRequest putRecordRequest = new PutRecordRequest();
                 putRecordRequest.setStreamName(config.KINESIS_INPUT_STREAM);
                 putRecordRequest.setData(ByteBuffer.wrap(line.getBytes()));
-                putRecordRequest.setPartitionKey(Integer.toString(kinesisMessageModel.getUserid()));
+                putRecordRequest.setPartitionKey(Integer.toString(kinesisMessageModel.getId()));
                 kinesisClient.putRecord(putRecordRequest);
                 lines++;
             }