[jira] [Commented] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15116494#comment-15116494 ] Hitoshi Ozawa commented on KAFKA-2704: -- My mistake - source was not fixed. Will creat

[jira] [Commented] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15116492#comment-15116492 ] Hitoshi Ozawa commented on KAFKA-2704: -- Just looked at the current source and it alre

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Reviewer: Jun Rao (was: Gwen Shapira) > SimpleConsumer.scala is declared as threadsafe but is not

[jira] [Updated] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2704: - Reviewer: Jun Rao (was: Gwen Shapira) > SimpleConsumer should throw InterruptedException when int

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Reviewer: Gwen Shapira (was: Jun Rao) > SimpleConsumer.scala is declared as threadsafe but is not

[jira] [Updated] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2704: - Reviewer: Gwen Shapira (was: Jun Rao) > SimpleConsumer should throw InterruptedException when int

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Reviewer: Jun Rao > SimpleConsumer.scala is declared as threadsafe but is not > --

[jira] [Updated] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2704: - Reviewer: Jun Rao (was: Aditya A Auradkar) > SimpleConsumer should throw InterruptedException whe

[jira] [Updated] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2704: - Reviewer: Aditya A Auradkar Status: Patch Available (was: Open) A patch to throw throw Inte

[jira] [Updated] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2704: - Attachment: simpleconsumer_2.patch A patch to throw InterruptedException when interrupted > Simpl

[jira] [Created] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

Hitoshi Ozawa created KAFKA-2704: Summary: SimpleConsumer should throw InterruptedException when interrupted Key: KAFKA-2704 URL: https://issues.apache.org/jira/browse/KAFKA-2704 Project: Kafka

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Attachment: simpleconsumer.patch Patch to make SimpleConsumer.scale threadsafe > SimpleConsumer.s

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Status: Patch Available (was: Open) I've made a pull request for the patch. https://github.com/ho

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Status: Open (was: Patch Available) > SimpleConsumer.scala is declared as threadsafe but is not >

[jira] [Issue Comment Deleted] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Comment: was deleted (was: The patch just adds @throws annotations to methods to make them thread

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Status: Patch Available (was: Open) The patch just adds @throws annotations to methods to make th

[jira] [Created] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

Hitoshi Ozawa created KAFKA-2703: Summary: SimpleConsumer.scala is declared as threadsafe but is not Key: KAFKA-2703 URL: https://issues.apache.org/jira/browse/KAFKA-2703 Project: Kafka Issue