[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-03-03 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894818#comment-15894818 ] Colin P. McCabe commented on KAFKA-4767: I agree that the interrupt state of the t

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-02-18 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15873290#comment-15873290 ] Buğra Gedik commented on KAFKA-4767: Agreed. I did not see ``this.sender.forceClose();

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-02-17 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871783#comment-15871783 ] Ismael Juma commented on KAFKA-4767: [~bgedik], `this.sender.forceClose();` is "some c

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15870121#comment-15870121 ] Buğra Gedik commented on KAFKA-4767: I understand that it will eventually gets shutdow

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-02-16 Thread huxi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15870055#comment-15870055 ] huxi commented on KAFKA-4767: - What do you mean by "leaking the IO thread"? Do you mean it cou

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-02-16 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869912#comment-15869912 ] Buğra Gedik commented on KAFKA-4767: I think we are getting close to understanding eac

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-02-15 Thread huxi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869382#comment-15869382 ] huxi commented on KAFKA-4767: - I think I might get the point of what you mean. What you really

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-02-15 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869240#comment-15869240 ] Buğra Gedik commented on KAFKA-4767: IMO: * An interrupt means immediate exit from w

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

2017-02-15 Thread huxi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15868943#comment-15868943 ] huxi commented on KAFKA-4767: - Seems that KafkaProducer already initiates a close to the IO th