Browse Source

KAFKA-7332; Update CORRUPT_MESSAGE exception message description

Author: Manikumar Reddy <manikumar.reddy@gmail.com>

Reviewers: Dong Lin <lindong28@gmail.com>

Closes #5638 from omkreddy/KAFKA-7332-COMPACTED-ERROR_MESSAGE
pull/5638/merge
Manikumar Reddy 6 years ago committed by Dong Lin
parent
commit
4bbbfaf39c
  1. 2
      clients/src/main/java/org/apache/kafka/common/protocol/Errors.java

2
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java

@ -116,7 +116,7 @@ public enum Errors { @@ -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),

Loading…
Cancel
Save