topic's partition have no leader and isr

2014-07-03 Thread 鞠大升
hi, all I have a topic with 32 partitions, after some reassign operation, 2 partitions became to no leader and isr. --- Topic:org.mobile_nginx PartitionCount:32

[jira] [Created] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-1519: --- Summary: Console consumer: expose configuration option to enable/disable writing the line separator Key: KAFKA-1519 URL: https://issues.apache.org/jira/browse/KAFKA-1519

[jira] [Updated] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-1519: Issue Type: Improvement (was: Bug) Console consumer: expose configuration option to

[jira] [Updated] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-1519: Description: The current console consumer includes a {{DefaultMessageFormatter}}, which exposes a

[jira] [Updated] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-1519: Description: The current console consumer includes a {{DefaultMessageFormatter}}, which exposes a

[jira] [Created] (KAFKA-1520) Tools for contributors

2014-07-03 Thread Evgeny Vereshchagin (JIRA)
Evgeny Vereshchagin created KAFKA-1520: -- Summary: Tools for contributors Key: KAFKA-1520 URL: https://issues.apache.org/jira/browse/KAFKA-1520 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051607#comment-14051607 ] Jun Rao commented on KAFKA-1519: Could you try sth like --property=line.separator=?

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051615#comment-14051615 ] Michael Noll commented on KAFKA-1519: - Unfortunately, those don't work either: {code}

[jira] [Commented] (KAFKA-1520) Tools for contributors

2014-07-03 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051619#comment-14051619 ] Jun Rao commented on KAFKA-1520: Thanks for creating that package. That can be very

Re: topic's partition have no leader and isr

2014-07-03 Thread Guozhang Wang
Did you see any errors on the controller log? Guozhang On Thu, Jul 3, 2014 at 2:26 AM, 鞠大升 dashen...@gmail.com wrote: hi, all I have a topic with 32 partitions, after some reassign operation, 2 partitions became to no leader and isr.

Review Request 23266: Fix KAFKA-1515

2014-07-03 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23266/ --- Review request for kafka. Bugs: KAFKA-1515

Re: Review Request 23266: Fix KAFKA-1515

2014-07-03 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23266/#review47302 --- clients/src/test/resources/log4j.properties

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051695#comment-14051695 ] Jun Rao commented on KAFKA-1519: Yes, it is a problem. What you suggested would fix the

[jira] [Updated] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

2014-07-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1515: - Attachment: KAFKA-1515_2014-07-03_10:19:28.patch Wake-up Sender upon blocked on fetching leader

Re: Review Request 23266: Fix KAFKA-1515

2014-07-03 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23266/ --- (Updated July 3, 2014, 5:19 p.m.) Review request for kafka. Bugs: KAFKA-1515

[jira] [Commented] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

2014-07-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051703#comment-14051703 ] Guozhang Wang commented on KAFKA-1515: -- Updated reviewboard

Re: Review Request 23266: Fix KAFKA-1515

2014-07-03 Thread Guozhang Wang
On July 3, 2014, 5:05 p.m., Jun Rao wrote: clients/src/test/resources/log4j.properties, lines 15-16 https://reviews.apache.org/r/23266/diff/1/?file=623581#file623581line15 Are those changes intended? Nope they are not.. - Guozhang

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051737#comment-14051737 ] Gwen Shapira commented on KAFKA-1519: - btw. I can't see any unit tests for command

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051714#comment-14051714 ] Gwen Shapira commented on KAFKA-1519: - Just supporting an empty value seems far more

Producer Graceful Shutdown issue in Container (Kafka version 0.8.x.x)

2014-07-03 Thread Bhavesh Mistry
Hi Kafka Team, We are running multiple webapps in tomcat container, and we have producer which are managed by the ServletContextListener (Lifecycle). Upon contextInitialized we create and on contextDestroyed we call the producer.close() but underlying Metric Lib does not shutdown. So we have

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051783#comment-14051783 ] Michael Noll commented on KAFKA-1519: - Btw, for others reading this ticket: In Kafka

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051790#comment-14051790 ] Michael Noll commented on KAFKA-1519: - Supporting an empty value is of course another

[jira] Subscription: outstanding kafka patches

2014-07-03 Thread jira
Issue Subscription Filter: outstanding kafka patches (96 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1515 Wake-up Sender upon blocked on fetching leader metadata https://issues.apache.org/jira/browse/KAFKA-1515 KAFKA-1512

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051899#comment-14051899 ] Jay Kreps commented on KAFKA-1512: -- A proposal from the LI ops team is to also add an

[jira] [Comment Edited] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051899#comment-14051899 ] Jay Kreps edited comment on KAFKA-1512 at 7/3/14 8:46 PM: -- A

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051909#comment-14051909 ] Jay Kreps commented on KAFKA-1519: -- I would also vote for supporting an empty separator

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051914#comment-14051914 ] Gwen Shapira commented on KAFKA-1512: - It sounds like I can completely block specific

[jira] [Commented] (KAFKA-1520) Tools for contributors

2014-07-03 Thread Evgeny Vereshchagin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051917#comment-14051917 ] Evgeny Vereshchagin commented on KAFKA-1520: It's demo version and too early

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051951#comment-14051951 ] Jay Kreps commented on KAFKA-1512: -- Yes, I hadn't thought of that. Disabling connections

[jira] [Commented] (KAFKA-1520) Tools for contributors

2014-07-03 Thread Evgeny Vereshchagin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051960#comment-14051960 ] Evgeny Vereshchagin commented on KAFKA-1520: {quote} Do we have instructions

Re: Review Request 23208: Patch for KAFKA-1512

2014-07-03 Thread Jay Kreps
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23208/ --- (Updated July 3, 2014, 10:18 p.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051973#comment-14051973 ] Jay Kreps commented on KAFKA-1512: -- Updated reviewboard

[jira] [Updated] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1512: - Attachment: KAFKA-1512_2014-07-03_15:17:55.patch Limit the maximum number of connections per ip address

Re: Review Request 23266: Fix KAFKA-1515

2014-07-03 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23266/ --- (Updated July 3, 2014, 11:42 p.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

2014-07-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14052007#comment-14052007 ] Guozhang Wang commented on KAFKA-1515: -- Updated reviewboard

[jira] [Updated] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

2014-07-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1515: - Attachment: KAFKA-1515_2014-07-03_16:43:05.patch Wake-up Sender upon blocked on fetching leader

[jira] [Created] (KAFKA-1521) Producer Graceful Shutdown issue in Container (Kafka version 0.8.x.x)

2014-07-03 Thread Bravesh Mistry (JIRA)
Bravesh Mistry created KAFKA-1521: - Summary: Producer Graceful Shutdown issue in Container (Kafka version 0.8.x.x) Key: KAFKA-1521 URL: https://issues.apache.org/jira/browse/KAFKA-1521 Project: Kafka

[jira] [Commented] (KAFKA-1521) Producer Graceful Shutdown issue in Container (Kafka version 0.8.x.x)

2014-07-03 Thread Bravesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14052056#comment-14052056 ] Bravesh Mistry commented on KAFKA-1521: --- Here is confirmation from [~guozhang] :

[jira] [Commented] (KAFKA-1521) Producer Graceful Shutdown issue in Container (Kafka version 0.8.x.x)

2014-07-03 Thread Bravesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14052062#comment-14052062 ] Bravesh Mistry commented on KAFKA-1521: --- Just for information, I am using Async mode

[jira] [Updated] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1519: Attachment: KAFKA-1519.patch Console consumer: expose configuration option to enable/disable

[jira] [Updated] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1519: Status: Patch Available (was: Open) Attached a patch. Note that I did not specifically test the

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14052113#comment-14052113 ] Jay Kreps commented on KAFKA-1519: -- Looks good. I think this change might also interpret

Re: Review Request 23266: Fix KAFKA-1515

2014-07-03 Thread Jay Kreps
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23266/#review47334 ---