adikou commented on PR #22270:
URL: https://github.com/apache/kafka/pull/22270#issuecomment-4557576846
I was thinking of something along the following lines:
```java
public enum RebalanceCause {
INITIAL_ASSIGNMENT, SUBSCRIPTION_CHANGE, POLL_TIMEOUT_EXCEEDED,
USER_INITIATED, MEMBER_FENCED, COORDINATOR_INITIATED, COORDINATOR_UNAVAILABLE,
UNKNOWN
}
```
and a
```java
public interface RebalanceContext {
RebalanceConsumer consumer();
RebalanceCause cause();
Optional<String> reason();
}
```
Right now we log these around at info, but generally people tend to set the
log levels of lower level libraries to error/warn so these can get lost.
We don't need to do this as part of this PR or KIP, but we can use the
Context holder design, mark it as `@Evolving`, add the cause/reason as a
follow-up.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
