[jira] [Commented] (KAFKA-10055) Add shared internal utility class for Streams module

[ https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142451#comment-17142451 ] Vito Jeng commented on KAFKA-10055: --- [~bchen225242] Got it. > Add shared internal utility class for

[jira] [Assigned] (KAFKA-10055) Add shared internal utility class for Streams module

[ https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vito Jeng reassigned KAFKA-10055: - Assignee: Vito Jeng > Add shared internal utility class for Streams module >

[jira] [Commented] (KAFKA-10055) Add shared internal utility class for Streams module

[ https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125407#comment-17125407 ] Vito Jeng commented on KAFKA-10055: --- [~mjsax] Can I take this? > Add shared internal utility class

[jira] [Commented] (KAFKA-9471) Throw exception for DEAD StreamThread.State

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022980#comment-17022980 ] Vito Jeng commented on KAFKA-9471: -- [~yuzhih...@gmail.com] Yes, I would be include this in KIP-216. >

[jira] [Commented] (KAFKA-9471) Throw exception for DEAD StreamThread.State

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022968#comment-17022968 ] Vito Jeng commented on KAFKA-9471: -- [~yuzhih...@gmail.com] Yes. Currently,

[jira] [Commented] (KAFKA-9471) Return empty collection for PENDING_SHUTDOWN

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022586#comment-17022586 ] Vito Jeng commented on KAFKA-9471: -- Thanks [~yuzhih...@gmail.com] point this. In KIP-216, we handle

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347957#comment-16347957 ] Vito Jeng commented on KAFKA-5876: -- [~Pegerto] Thanks! > IQ should throw different exceptions for

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195313#comment-16195313 ] Vito Jeng commented on KAFKA-5876: -- Thanks. I'll write my first KIP. ;) > IQ should throw different

[jira] [Assigned] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vito Jeng reassigned KAFKA-5876: Assignee: Vito Jeng > IQ should throw different exceptions for different errors >

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194325#comment-16194325 ] Vito Jeng commented on KAFKA-5876: -- Could I work on this issue? > IQ should throw different exceptions