lianetm commented on code in PR #15579:
URL: https://github.com/apache/kafka/pull/15579#discussion_r1536155967
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##########
@@ -1070,29 +1081,27 @@ private SortedSet<TopicPartition>
toTopicPartitionSet(SortedSet<TopicIdPartition
/**
* @return Reason for interrupting a reconciliation progress when
callbacks complete.
*/
- private String interruptedReconciliationErrorMessage() {
- String reason;
- if (state != MemberState.RECONCILING) {
- reason = "The member already transitioned out of the reconciling
state into " + state;
- } else {
- reason = "The member has re-joined the group.";
+ private String interruptedReconciliationReason() {
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
