[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2016-11-10 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15654191#comment-15654191 ] Stig Rohde Døssing commented on KAFKA-1894: --- Suggestion for a fix for this issue here

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2016-11-09 Thread Shixiong Zhu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15651799#comment-15651799 ] Shixiong Zhu commented on KAFKA-1894: - Hit the same issue in Spark Structured Streaming Kafka Source.

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2016-11-09 Thread Catalina-Alina Dobrica (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15650814#comment-15650814 ] Catalina-Alina Dobrica commented on KAFKA-1894: --- This issue also prevents the consumer's

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2016-06-14 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15330848#comment-15330848 ] Edoardo Comar commented on KAFKA-1894: -- Another case that leads to the loop ``` public void

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2015-12-09 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15049441#comment-15049441 ] Jason Gustafson commented on KAFKA-1894: There's been a ton of movement on the new consumer since

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2015-12-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15036256#comment-15036256 ] Guozhang Wang commented on KAFKA-1894: -- [~BigAndy] You can indeed interrupt the poll() call by

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2015-12-02 Thread The Data Lorax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15035665#comment-15035665 ] The Data Lorax commented on KAFKA-1894: --- I'm running into this issue and struggling to find a way

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2015-10-07 Thread Onur Karaman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14947277#comment-14947277 ] Onur Karaman commented on KAFKA-1894: - Just for reference, this is similar to the following ticket:

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2015-10-07 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14947298#comment-14947298 ] Jason Gustafson commented on KAFKA-1894: [~onurkaraman] Maybe we clarify the scope of this issue.

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2015-10-05 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944043#comment-14944043 ] Ismael Juma commented on KAFKA-1894: `NetworkClient.completeAll` has thankfully been removed, so