You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by kk...@apache.org on 2020/04/21 07:07:10 UTC
[kafka] branch 2.5 updated: MINOR: Fix grammar in error message for
InvalidRecordException (#8465)
This is an automated email from the ASF dual-hosted git repository.
kkarantasis pushed a commit to branch 2.5
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.5 by this push:
new 867f031 MINOR: Fix grammar in error message for InvalidRecordException (#8465)
867f031 is described below
commit 867f031322ee2e293af01f2a2a3760bfef39f160
Author: Tu V. Tran <tu...@gmail.com>
AuthorDate: Mon Apr 20 23:52:57 2020 -0700
MINOR: Fix grammar in error message for InvalidRecordException (#8465)
* Fix error message for InvalidRecordException
* Update clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
Co-authored-by: Konstantine Karantasis <ko...@confluent.io>
---
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 246545e..997f201 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,8 +318,8 @@ 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),
- UNSTABLE_OFFSET_COMMIT(88, "There are unstable offsets that need to be cleared", UnstableOffsetCommitException::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);