[jira] [Updated] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-02-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-695: -- Attachment: kafka-695_followup_v2.patch Attach followup patch v2. Broker shuts down due to

[jira] [Commented] (KAFKA-749) Bug in socket server shutdown logic makes the broker hang on shutdown until it has to be killed

2013-02-05 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571355#comment-13571355 ] Jay Kreps commented on KAFKA-749: - Err, should be while(true) { queue.clear()

[jira] [Commented] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-02-05 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571427#comment-13571427 ] Jay Kreps commented on KAFKA-695: - Can we just remove the interrupt entirely instead of

[jira] [Commented] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-02-05 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571427#comment-13571427 ] Jay Kreps commented on KAFKA-695: - Can we just remove the interrupt entirely instead of

[jira] [Commented] (KAFKA-736) Add an option to the 0.8 producer to mimic 0.7 producer behavior

2013-02-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571485#comment-13571485 ] Neha Narkhede commented on KAFKA-736: - Producer performance does not measure latency

[jira] [Updated] (KAFKA-736) Add an option to the 0.8 producer to mimic 0.7 producer behavior

2013-02-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-736: Attachment: kafka-736-v3-producer-latency-20threads-acks1.out

[jira] [Commented] (KAFKA-749) Bug in socket server shutdown logic makes the broker hang on shutdown until it has to be killed

2013-02-05 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571511#comment-13571511 ] Sriram Subramanian commented on KAFKA-749: -- If that works fine. But it looks like

[jira] [Updated] (KAFKA-749) Bug in socket server shutdown logic makes the broker hang on shutdown until it has to be killed

2013-02-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-749: Attachment: kafka-749-v2.patch Thanks for the review ! I think I was over thinking the issue of

[jira] [Commented] (KAFKA-749) Bug in socket server shutdown logic makes the broker hang on shutdown until it has to be killed

2013-02-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571520#comment-13571520 ] Neha Narkhede commented on KAFKA-749: - Sriram, That is what I had described in my

[jira] [Commented] (KAFKA-749) Bug in socket server shutdown logic makes the broker hang on shutdown until it has to be killed

2013-02-05 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571585#comment-13571585 ] Jay Kreps commented on KAFKA-749: - Also, not sure if I get it. If the I/O threads are able

[jira] [Commented] (KAFKA-749) Bug in socket server shutdown logic makes the broker hang on shutdown until it has to be killed

2013-02-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571625#comment-13571625 ] Neha Narkhede commented on KAFKA-749: - That is correct. Also, removing the

[jira] [Created] (KAFKA-751) Fix windows build script - kafka-run-class.bat

2013-02-05 Thread Mark deVilliers (JIRA)
Mark deVilliers created KAFKA-751: - Summary: Fix windows build script - kafka-run-class.bat Key: KAFKA-751 URL: https://issues.apache.org/jira/browse/KAFKA-751 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-751) Fix windows build script - kafka-run-class.bat

2013-02-05 Thread Mark deVilliers (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark deVilliers updated KAFKA-751: -- Description: I've updated the kafka-run-class.bat to keep it in line (and working) with the

[jira] [Updated] (KAFKA-751) Fix windows build script - kafka-run-class.bat

2013-02-05 Thread Mark deVilliers (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark deVilliers updated KAFKA-751: -- Attachment: kafka-run-class.diff Fix windows build script - kafka-run-class.bat

[jira] [Assigned] (KAFKA-745) Remove getShutdownReceive() and other kafka specific code from the RequestChannel

2013-02-05 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian reassigned KAFKA-745: Assignee: Sriram Subramanian (was: Jun Rao) Remove getShutdownReceive() and

[jira] [Commented] (KAFKA-745) Remove getShutdownReceive() and other kafka specific code from the RequestChannel

2013-02-05 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571720#comment-13571720 ] Sriram Subramanian commented on KAFKA-745: -- I would like to take this and complete

[jira] [Closed] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-02-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-695. --- Broker shuts down due to attempt to read a closed index file

[jira] [Resolved] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-02-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-695. - Resolution: Fixed Broker shuts down due to attempt to read a closed index file

[jira] [Updated] (KAFKA-749) Bug in socket server shutdown logic makes the broker hang on shutdown until it has to be killed

2013-02-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-749: Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the reviews, checked

[jira] [Commented] (KAFKA-745) Remove getShutdownReceive() and other kafka specific code from the RequestChannel

2013-02-05 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13572229#comment-13572229 ] Sriram Subramanian commented on KAFKA-745: -- Took a look at this. The main issue is