[
https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16151516#comment-16151516
]
ASF GitHub Bot commented on KAFKA-5818:
---
GitHub user mjsax opened a pull request:
[
https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16151431#comment-16151431
]
ASF GitHub Bot commented on KAFKA-5818:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16149980#comment-16149980
]
Ted Yu commented on KAFKA-5818:
---
{code}
public synchronized boolean isRunningAndNotRebalancing() {
[
https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16149975#comment-16149975
]
Guozhang Wang commented on KAFKA-5818:
--
Yes, because state is volatile, we only need to synchronize
[
https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16149786#comment-16149786
]
Ted Yu commented on KAFKA-5818:
---
Looking at StreamThread, in the call chain run() -> runLoop() -> runOnce()
[
https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16149726#comment-16149726
]
ASF GitHub Bot commented on KAFKA-5818:
---
GitHub user mjsax opened a pull request:
