Adding some logging

jessecollier · Apr 13, 2017 · e790aa8 · e790aa8
1 parent c41173f
commit e790aa8
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/main/java/dbtucker/connect/kinesis/KinesisSinkTask.java b/src/main/java/dbtucker/connect/kinesis/KinesisSinkTask.java
@@ -76,8 +76,12 @@ public void put(Collection<SinkRecord> collection) {
         final PutRecordsRequestEntry put = new PutRecordsRequestEntry();
         put.setData(ByteBuffer.wrap(record.value().toString().getBytes()));
         if (record.key() != null) {
+            log.warn("I have a non-null record.key()=>'" + record.key() + "' record.value()=>'" + record.value() 
+                      + "' record.topic()=>'" + record.topic() + "' toSring()=>'" + record.key().toString() + "'"
+              );
             if (record.keySchema() != null) {
                 // TODO: correctly parse schema'ed key
+
                 put.setPartitionKey(record.key().toString());   // assume toString handles real Strings correctly
             } else {
                 put.setPartitionKey(record.key().toString());   // assume toString handles real Strings correctly