From bb3f6719f2eebf19ed23eb85226cbe146edbaadb Mon Sep 17 00:00:00 2001 From: Tom Bentley Date: Tue, 25 Feb 2020 11:30:36 +0000 Subject: [PATCH] MINOR: Consistent terminal period in Errors.defaultExceptionMessage --- .../apache/kafka/common/protocol/Errors.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 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 246545e3ef9aa..72a82b0e4d311 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 @@ -292,34 +292,34 @@ public enum Errors { ListenerNotFoundException::new), TOPIC_DELETION_DISABLED(73, "Topic deletion is disabled.", TopicDeletionDisabledException::new), - FENCED_LEADER_EPOCH(74, "The leader epoch in the request is older than the epoch on the broker", + FENCED_LEADER_EPOCH(74, "The leader epoch in the request is older than the epoch on the broker.", FencedLeaderEpochException::new), - UNKNOWN_LEADER_EPOCH(75, "The leader epoch in the request is newer than the epoch on the broker", + UNKNOWN_LEADER_EPOCH(75, "The leader epoch in the request is newer than the epoch on the broker.", UnknownLeaderEpochException::new), UNSUPPORTED_COMPRESSION_TYPE(76, "The requesting client does not support the compression type of given partition.", UnsupportedCompressionTypeException::new), - STALE_BROKER_EPOCH(77, "Broker epoch has changed", + STALE_BROKER_EPOCH(77, "Broker epoch has changed.", StaleBrokerEpochException::new), OFFSET_NOT_AVAILABLE(78, "The leader high watermark has not caught up from a recent leader " + - "election so the offsets cannot be guaranteed to be monotonically increasing", + "election so the offsets cannot be guaranteed to be monotonically increasing.", OffsetNotAvailableException::new), - MEMBER_ID_REQUIRED(79, "The group member needs to have a valid member id before actually entering a consumer group", + MEMBER_ID_REQUIRED(79, "The group member needs to have a valid member id before actually entering a consumer group.", MemberIdRequiredException::new), - PREFERRED_LEADER_NOT_AVAILABLE(80, "The preferred leader was not available", + PREFERRED_LEADER_NOT_AVAILABLE(80, "The preferred leader was not available.", PreferredLeaderNotAvailableException::new), GROUP_MAX_SIZE_REACHED(81, "The consumer group has reached its max size.", GroupMaxSizeReachedException::new), FENCED_INSTANCE_ID(82, "The broker rejected this static consumer since " + "another consumer with the same group.instance.id has registered with a different member.id.", FencedInstanceIdException::new), - ELIGIBLE_LEADERS_NOT_AVAILABLE(83, "Eligible topic partition leaders are not available", + ELIGIBLE_LEADERS_NOT_AVAILABLE(83, "Eligible topic partition leaders are not available.", EligibleLeadersNotAvailableException::new), - ELECTION_NOT_NEEDED(84, "Leader election not needed for topic partition", ElectionNotNeededException::new), + ELECTION_NOT_NEEDED(84, "Leader election not needed for topic partition.", ElectionNotNeededException::new), NO_REASSIGNMENT_IN_PROGRESS(85, "No partition reassignment is in progress.", 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); + UNSTABLE_OFFSET_COMMIT(88, "There are unstable offsets that need to be cleared.", UnstableOffsetCommitException::new); private static final Logger log = LoggerFactory.getLogger(Errors.class);