[kafka] branch trunk updated: KAFKA-7332; Update CORRUPT_MESSAGE exception message description

[li...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lindong pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 4bbbfaf  KAFKA-7332; Update CORRUPT_MESSAGE exception message description
4bbbfaf is described below

commit 4bbbfaf39c79fc5dfa7fbc22842717b0fad13503
Author: Manikumar Reddy <ma...@gmail.com>
AuthorDate: Tue Sep 18 01:01:54 2018 -0700

    KAFKA-7332; Update CORRUPT_MESSAGE exception message description
    
    Author: Manikumar Reddy <ma...@gmail.com>
    
    Reviewers: Dong Lin <li...@gmail.com>
    
    Closes #5638 from omkreddy/KAFKA-7332-COMPACTED-ERROR_MESSAGE
---
 clients/src/main/java/org/apache/kafka/common/protocol/Errors.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java b/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
index a796ec9..082eff1 100644
--- a/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
+++ b/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
@@ -116,7 +116,7 @@ public enum Errors {
     NONE(0, null, message -> null),
     OFFSET_OUT_OF_RANGE(1, "The requested offset is not within the range of offsets maintained by the server.",
             OffsetOutOfRangeException::new),
-    CORRUPT_MESSAGE(2, "This message has failed its CRC checksum, exceeds the valid size, or is otherwise corrupt.",
+    CORRUPT_MESSAGE(2, "This message has failed its CRC checksum, exceeds the valid size, has a null key for a compacted topic, or is otherwise corrupt.",
             CorruptRecordException::new),
     UNKNOWN_TOPIC_OR_PARTITION(3, "This server does not host this topic-partition.",
             UnknownTopicOrPartitionException::new),