[kinesis] Improved partition key handling

debezium · Aug 30, 2018 · 4f01d0f · 4f01d0f
1 parent 98fdee0
commit 4f01d0f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kinesis/src/main/java/io/debezium/examples/kinesis/ChangeDataSender.java b/kinesis/src/main/java/io/debezium/examples/kinesis/ChangeDataSender.java
@@ -114,7 +114,7 @@ private void sendRecord(SourceRecord record) {
         message.put("key", record.key());
         message.put("value", record.value());
 
-        String partitionKey = String.valueOf(record.key() != null ? record.key().hashCode() : new Object().hashCode());
+        String partitionKey = String.valueOf(record.key() != null ? record.key().hashCode() : -1);
         final byte[] payload = valueConverter.fromConnectData("dummy", schema, message);
 
         PutRecordRequest putRecord = new PutRecordRequest();