From 4bbbfaf39c79fc5dfa7fbc22842717b0fad13503 Mon Sep 17 00:00:00 2001 From: Manikumar Reddy Date: Tue, 18 Sep 2018 01:01:54 -0700 Subject: [PATCH] KAFKA-7332; Update CORRUPT_MESSAGE exception message description Author: Manikumar Reddy Reviewers: Dong Lin Closes #5638 from omkreddy/KAFKA-7332-COMPACTED-ERROR_MESSAGE --- .../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 a796ec912cb..082eff12461 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),