From 3e1103872e33a57f0fb8c424f08f0aac98bbf314 Mon Sep 17 00:00:00 2001 From: Tu Tran Date: Fri, 10 Apr 2020 20:03:41 -0700 Subject: [PATCH 1/2] Fix error message for InvalidRecordException --- .../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 72a82b0e4d311..e416195069648 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 @@ -318,7 +318,7 @@ public enum Errors { NoReassignmentInProgressException::new), GROUP_SUBSCRIBED_TO_TOPIC(86, "Deleting offsets of a topic is forbidden while the consumer group is actively subscribed to it.", GroupSubscribedToTopicException::new), - INVALID_RECORD(87, "This record has failed the validation on broker and hence be rejected.", InvalidRecordException::new), + INVALID_RECORD(87, "This record has failed the validation on broker and will hence be rejected.", InvalidRecordException::new), UNSTABLE_OFFSET_COMMIT(88, "There are unstable offsets that need to be cleared.", UnstableOffsetCommitException::new); private static final Logger log = LoggerFactory.getLogger(Errors.class); From df7bc72ab159bc085cb03aa92828d1a27c823d7e Mon Sep 17 00:00:00 2001 From: "Tu V. Tran" Date: Thu, 16 Apr 2020 14:14:48 -0700 Subject: [PATCH 2/2] Update clients/src/main/java/org/apache/kafka/common/protocol/Errors.java Co-Authored-By: Konstantine Karantasis --- .../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 e416195069648..526b4dfc0ba04 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 @@ -318,7 +318,7 @@ public enum Errors { NoReassignmentInProgressException::new), GROUP_SUBSCRIBED_TO_TOPIC(86, "Deleting offsets of a topic is forbidden while the consumer group is actively subscribed to it.", GroupSubscribedToTopicException::new), - INVALID_RECORD(87, "This record has failed the validation on broker and will hence be rejected.", InvalidRecordException::new), + INVALID_RECORD(87, "This record has failed the validation on broker and hence will be rejected.", InvalidRecordException::new), UNSTABLE_OFFSET_COMMIT(88, "There are unstable offsets that need to be cleared.", UnstableOffsetCommitException::new); private static final Logger log = LoggerFactory.getLogger(Errors.class);