root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Small logging fixes in AbstractCoordinator (#7230) 

Reviewers: Jason Gustafson <jason@confluent.io>
This commit is contained in:
Mickael Maison 2019-11-18 22:32:08 +00:00 committed by Jason Gustafson
parent 9fb22868fe
commit 305f134abf
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
View File

@ -610,7 +610,7 @@ public abstract class AbstractCoordinator implements Closeable {
}
} else if (error == Errors.UNSUPPORTED_VERSION) {
log.error("Attempt to join group failed due to unsupported version error. Please unset field group.instance.id and retry" +
"to see if the problem resolves");
" to see if the problem resolves");
future.raise(error);
} else if (error == Errors.MEMBER_ID_REQUIRED) {
// Broker requires a concrete member id to be allowed to join the group. Update member id
@ -852,7 +852,7 @@ public abstract class AbstractCoordinator implements Closeable {
}
synchronized void resetGenerationOnResponseError(ApiKeys api, Errors error) {
log.debug("Resetting generation after encountering " + error + " from " + api + " response");
log.debug("Resetting generation after encountering {} from {} response", error, api);
resetGeneration();
}
@ -1339,6 +1339,7 @@ public abstract class AbstractCoordinator implements Closeable {
}
}
@SuppressWarnings("serial")
private static class UnjoinedGroupException extends RetriableException {
}