kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: MINOR: Add another common error case for CorruptRecordException's error message
Date Tue, 18 Jul 2017 20:01:07 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk ea8845bbd -> fc0ea2502


MINOR: Add another common error case for CorruptRecordException's error message

Author: Ewen Cheslack-Postava <me@ewencp.org>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #3541 from ewencp/corrupt-record-null-key-compacted-topic


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

Branch: refs/heads/trunk
Commit: fc0ea25025df8af5079e8142ba085939b3c9c073
Parents: ea8845b
Author: Ewen Cheslack-Postava <me@ewencp.org>
Authored: Tue Jul 18 13:00:46 2017 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Tue Jul 18 13:00:46 2017 -0700

----------------------------------------------------------------------
 .../org/apache/kafka/common/errors/CorruptRecordException.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/fc0ea250/clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java
b/clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java
index 1eac621..abcf516 100644
--- a/clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java
+++ b/clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java
@@ -25,7 +25,7 @@ public class CorruptRecordException extends RetriableException {
     private static final long serialVersionUID = 1L;
 
     public CorruptRecordException() {
-        super("This message has failed its CRC checksum, exceeds the valid size, or is otherwise
corrupt.");
+        super("This message has failed its CRC checksum, exceeds the valid size, has a null
key for a compacted topic, or is otherwise corrupt.");
     }
 
     public CorruptRecordException(String message) {


Mime
View raw message