Merge pull request #167 from jimjh/patch-1

reset pKey when message#key is null
LinkedInAttic · Feb 21, 2015 · daf9686 · daf9686
2 parents 017b61c + 3695ea5
commit daf9686
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/common/KafkaReader.java b/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/common/KafkaReader.java
@@ -116,6 +116,9 @@ public boolean getNext(EtlKey key, BytesWritable payload, BytesWritable pKey) th
         bytes = new byte[origSize];
         buf.get(bytes, buf.position(), origSize);
         pKey.set(bytes, 0, origSize);
+      } else {
+        log.warn("Received message with null message.key(): " + msgAndOffset);
+        pKey.setSize(0);
       }
 
       key.clear();