[jira] [Commented] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533252#comment-16533252 ] Richard Yu commented on KAFKA-7132: --- Hi all, You could find the KIP here. (Discussion thread TBD)

[jira] [Comment Edited] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533252#comment-16533252 ] Richard Yu edited comment on KAFKA-7132 at 7/5/18 4:30 AM: --- Hi all, You could

[jira] [Issue Comment Deleted] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-7132: -- Comment: was deleted (was: Well, when I was imagining this situation, I was thinking that the log's

[jira] [Commented] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533162#comment-16533162 ] Richard Yu commented on KAFKA-7132: --- Well, when I was imagining this situation, I was thinking that the

[jira] [Commented] (KAFKA-6904) DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky

[ https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533150#comment-16533150 ] Ted Yu commented on KAFKA-6904: --- Haven't seen this failure lately. >

[jira] [Commented] (KAFKA-7125) Calling StreamsBuilderbuilder.build().describe() causes java.util.NoSuchElementException: null

[ https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533062#comment-16533062 ] Guozhang Wang commented on KAFKA-7125: -- Thanks [~Ahto]. Regarding the documentation, with the

[jira] [Commented] (KAFKA-7130) EOFException after rolling log segment

[ https://issues.apache.org/jira/browse/KAFKA-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533035#comment-16533035 ] Dhruvil Shah commented on KAFKA-7130: - [~kschnitter] it would be useful if you could save the

[jira] [Commented] (KAFKA-7125) Calling StreamsBuilderbuilder.build().describe() causes java.util.NoSuchElementException: null

[ https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533017#comment-16533017 ] Jouni commented on KAFKA-7125: -- Thanks Guozhang. Process method not being called, could be because I'm

[jira] [Commented] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532997#comment-16532997 ] Guozhang Wang commented on KAFKA-6127: -- That is a good question. I think we should consider whether

[jira] [Commented] (KAFKA-7125) Calling StreamsBuilderbuilder.build().describe() causes java.util.NoSuchElementException: null

[ https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532992#comment-16532992 ] Guozhang Wang commented on KAFKA-7125: -- [~Ahto] I think with my PR, adding just a processor, not

[jira] [Commented] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532980#comment-16532980 ] Guozhang Wang commented on KAFKA-7132: -- [~Yohan123] There are two things we should consider here,

[jira] [Created] (KAFKA-7133) DisconnectException every 5 minutes in single restore consumer thread

Chris Schwarzfischer created KAFKA-7133: --- Summary: DisconnectException every 5 minutes in single restore consumer thread Key: KAFKA-7133 URL: https://issues.apache.org/jira/browse/KAFKA-7133

[jira] [Commented] (KAFKA-6751) Make max.connections.per.ip.overrides a dynamic config

[ https://issues.apache.org/jira/browse/KAFKA-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532587#comment-16532587 ] ASF GitHub Bot commented on KAFKA-6751: --- omkreddy opened a new pull request #5334: KAFKA-6751:

[jira] [Commented] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532545#comment-16532545 ] Stanislav Kozlovski commented on KAFKA-7132: The best way to consider this is to open a KIP

[jira] [Updated] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-7132: -- Labels: performance (was: ) > Consider adding faster form of rebalancing >

[jira] [Updated] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-7132: -- Priority: Critical (was: Major) > Consider adding faster form of rebalancing >

[jira] [Updated] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-7132: -- Summary: Consider adding faster form of rebalancing (was: Consider adding multithreaded form of

[jira] [Updated] (KAFKA-7132) Consider adding multithreaded form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-7132: -- Description: Currently, when a consumer falls out of a consumer group, it will restart processing from

[jira] [Updated] (KAFKA-7132) Consider adding multithreaded form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-7132: -- Summary: Consider adding multithreaded form of rebalancing (was: Consider adding multithreaded form

[jira] [Created] (KAFKA-7132) Consider adding multithreaded form of recovery

Richard Yu created KAFKA-7132: - Summary: Consider adding multithreaded form of recovery Key: KAFKA-7132 URL: https://issues.apache.org/jira/browse/KAFKA-7132 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7130) EOFException after rolling log segment

[ https://issues.apache.org/jira/browse/KAFKA-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532391#comment-16532391 ] Karsten Schnitter commented on KAFKA-7130: -- I saved the faulty segments from the last incident.

[jira] [Commented] (KAFKA-7130) EOFException after rolling log segment

[ https://issues.apache.org/jira/browse/KAFKA-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532366#comment-16532366 ] Karsten Schnitter commented on KAFKA-7130: -- The stack trace of the original system was lost.

[jira] [Commented] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532315#comment-16532315 ] ASF GitHub Bot commented on KAFKA-6127: --- ConcurrencyPractitioner opened a new pull request #5333:

[jira] [Commented] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532301#comment-16532301 ] Richard Yu commented on KAFKA-6127: --- Hi [~guozhang] Now that we have created new methods (for

[jira] [Assigned] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu reassigned KAFKA-6127: - Assignee: Richard Yu > Streams should never block infinitely >