showuon commented on a change in pull request #9627:
URL: https://github.com/apache/kafka/pull/9627#discussion_r618159827
##########
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##########
@@ -1001,9 +1001,14 @@ protected void close(Timer timer) {
}
/**
+ * Leave the group. This method also sends LeaveGroupRequest and log
{@code leaveReason} if this is dynamic members
+ * or unknown coordinator or state is not UNJOINED or this generation has
a valid member id.
+ *
+ * @param leaveReason the reason to leave the group for logging
+ * @param shouldWarn should log as WARN level or INFO
* @throws KafkaException if the rebalance callback throws exception
*/
- public synchronized RequestFuture<Void> maybeLeaveGroup(String
leaveReason) {
+ public synchronized RequestFuture<Void> maybeLeaveGroup(String
leaveReason, boolean shouldWarn) throws KafkaException {
Review comment:
Cool! And, it cannot change to `protected` method since we used this
method in `KafkaConsumer`, which is in different package.
--
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
