You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2016/10/24 05:32:10 UTC

kafka git commit: MINOR: Check for null timestamp rather than value in hashcode

Repository: kafka
Updated Branches:
  refs/heads/trunk 63da48721 -> ed5076923


MINOR: Check for null timestamp rather than value in hashcode

Author: Andrew Stevenson <an...@datamountaineer.com>

Reviewers: Shikhar Bhushan <sh...@confluent.io>, Ewen Cheslack-Postava <ew...@confluent.io>

Closes #2055 from andrewstevenson/kafka-4334


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ed507692
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ed507692
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ed507692

Branch: refs/heads/trunk
Commit: ed5076923483bba36df6d4b70575ee0ffd6a046c
Parents: 63da487
Author: Andrew Stevenson <an...@datamountaineer.com>
Authored: Sun Oct 23 22:32:03 2016 -0700
Committer: Ewen Cheslack-Postava <me...@ewencp.org>
Committed: Sun Oct 23 22:32:03 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/connect/connector/ConnectRecord.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ed507692/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java b/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
index 25690a2..d6319a1 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
@@ -125,7 +125,7 @@ public abstract class ConnectRecord {
         result = 31 * result + (key != null ? key.hashCode() : 0);
         result = 31 * result + (valueSchema != null ? valueSchema.hashCode() : 0);
         result = 31 * result + (value != null ? value.hashCode() : 0);
-        result = 31 * result + (value != null ? timestamp.hashCode() : 0);
+        result = 31 * result + (timestamp != null ? timestamp.hashCode() : 0);
         return result;
     }
 }