[
https://issues.apache.org/jira/browse/KAFKA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212560#comment-14212560
]
Ewen Cheslack-Postava commented on KAFKA-1745:
--
[~Vishal M] I'm not sure what
[
https://issues.apache.org/jira/browse/KAFKA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14209628#comment-14209628
]
Vishal commented on KAFKA-1745:
---
Any solutions?
Each new thread creates a PIPE and KQUEUE
[
https://issues.apache.org/jira/browse/KAFKA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14202291#comment-14202291
]
Ewen Cheslack-Postava commented on KAFKA-1745:
--
[~Vishal M] I looked into
[
https://issues.apache.org/jira/browse/KAFKA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14197908#comment-14197908
]
Vishal commented on KAFKA-1745:
---
No, since I figured that calling producer.close() and
[
https://issues.apache.org/jira/browse/KAFKA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14198537#comment-14198537
]
Jun Rao commented on KAFKA-1745:
If you don't call producer.close(), the socket
[
https://issues.apache.org/jira/browse/KAFKA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14198787#comment-14198787
]
Ewen Cheslack-Postava commented on KAFKA-1745:
--
[~junrao] I think he was
[
https://issues.apache.org/jira/browse/KAFKA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14199817#comment-14199817
]
Vishal commented on KAFKA-1745:
---
[~junrao] Sorry, I should have been more clear.
[~ewencp] I
[
https://issues.apache.org/jira/browse/KAFKA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14195561#comment-14195561
]
Jun Rao commented on KAFKA-1745:
Did you call producer.close() when the producer thread is