Repository: kafka Updated Branches: refs/heads/trunk ea8845bbd -> fc0ea2502
MINOR: Add another common error case for CorruptRecordException's error message Author: Ewen Cheslack-Postava <[email protected]> Reviewers: Ismael Juma <[email protected]> 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 <[email protected]> Authored: Tue Jul 18 13:00:46 2017 -0700 Committer: Ewen Cheslack-Postava <[email protected]> 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) {
