[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-14 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061770#comment-14061770 ] Manikumar Reddy commented on KAFKA-1535: I think you should work on trunk. > ret

[jira] [Comment Edited] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-14 Thread Nicolae Marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061766#comment-14061766 ] Nicolae Marasoiu edited comment on KAFKA-1535 at 7/15/14 6:48 AM: --

[jira] [Comment Edited] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-14 Thread Nicolae Marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061766#comment-14061766 ] Nicolae Marasoiu edited comment on KAFKA-1535 at 7/15/14 6:46 AM: --

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-14 Thread Nicolae Marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061766#comment-14061766 ] Nicolae Marasoiu commented on KAFKA-1535: - Which branch should this be done on? tr

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-14 Thread Dmitry Bugaychenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061731#comment-14061731 ] Dmitry Bugaychenko commented on KAFKA-1414: --- Any plans regarding parallel shutdo

[jira] [Commented] (KAFKA-1539) Due to OS caching Kafka might loose offset files which causes full reset of data

2014-07-14 Thread Dmitry Bugaychenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061724#comment-14061724 ] Dmitry Bugaychenko commented on KAFKA-1539: --- It looks like even after flush data

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-14 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061708#comment-14061708 ] nicu marasoiu commented on KAFKA-1535: -- I will start working on this, hope to have a

[jira] [Commented] (KAFKA-1539) Due to OS caching Kafka might loose offset files which causes full reset of data

2014-07-14 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061613#comment-14061613 ] Jun Rao commented on KAFKA-1539: Hmm, interesting. The way that we checkpoint those offset

[jira] [Commented] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

2014-07-14 Thread Jason Rosenberg (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061599#comment-14061599 ] Jason Rosenberg commented on KAFKA-1180: anything more to be done to get this acro

Re: New Consumer Design

2014-07-14 Thread Baran Nohutçuoğlu
On Jul 8, 2014, at 3:17 PM, Guozhang Wang wrote: > Hi All, > > We have written a wiki a few weeks back proposing a single-threaded ZK-free > consumer client design for 0.9: > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+0.9+Consumer+Rewrite+Design > > We want to share some of the

[jira] [Commented] (KAFKA-1483) Split Brain about Leader Partitions

2014-07-14 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061512#comment-14061512 ] Sriharsha Chintalapani commented on KAFKA-1483: --- Created reviewboard https:/

[jira] [Updated] (KAFKA-1483) Split Brain about Leader Partitions

2014-07-14 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1483: -- Attachment: KAFKA-1483.patch > Split Brain about Leader Partitions > --

Review Request 23474: Patch for KAFKA-1483

2014-07-14 Thread Sriharsha Chintalapani
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23474/ --- Review request for kafka. Bugs: KAFKA-1483 https://issues.apache.org/jira/b

[jira] [Comment Edited] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-14 Thread Anton Karamanov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061230#comment-14061230 ] Anton Karamanov edited comment on KAFKA-1414 at 7/14/14 9:00 PM: ---

[jira] [Updated] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-14 Thread Anton Karamanov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Karamanov updated KAFKA-1414: --- Attachment: parallel-dir-loading-trunk-fixed-threadpool.patch Hi. I've checked that {{.getCa

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

2014-07-14 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061178#comment-14061178 ] Jay Kreps commented on KAFKA-1512: -- Updated reviewboard https://reviews.apache.org/r/2320

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

2014-07-14 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-14_13:28:15.patch > Limit the maximum number of connections per ip address

Re: Review Request 23208: Patch for KAFKA-1512

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

Re: Review Request 23208: Patch for KAFKA-1512

2014-07-14 Thread Jay Kreps
> On July 6, 2014, 7:34 p.m., Jun Rao wrote: > > I think what I have may be right. My understanding is that - InetAddress is an IP address - SocketAddress, InetSocketAddress are host/port pairs (basically) getInetAddress gets the remote ip address whereas getRemoteAddress gets the InetSocketA

[jira] Subscription: outstanding kafka patches

2014-07-14 Thread jira
Issue Subscription Filter: outstanding kafka patches (101 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1538 TEST JIRA for KAFKA-1536 https://issues.apache.org/jira/browse/KAFKA-1538 KAFKA-1531 zookeeper.connection.timeout.ms i

[jira] [Commented] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

2014-07-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14060839#comment-14060839 ] Guozhang Wang commented on KAFKA-1180: -- LGTM, +1. Patch applied with some line number

[jira] [Commented] (KAFKA-1377) transient unit test failure in LogOffsetTest

2014-07-14 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14060753#comment-14060753 ] Manikumar Reddy commented on KAFKA-1377: Yes. I am observing these failures on tru

Re: Can I get a review on KAFKA-1512?

2014-07-14 Thread Jay Kreps
Oops, missed that he had already reviewed... -Jay On Sat, Jul 12, 2014 at 7:26 PM, Gwen Shapira wrote: > Looks like Jun's comments on review board were not addressed? > They seem valid to me - especially the points about IPv6 (seen this at some > customers) and InetAddress having both host and p

[jira] [Commented] (KAFKA-1377) transient unit test failure in LogOffsetTest

2014-07-14 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14060720#comment-14060720 ] Jun Rao commented on KAFKA-1377: Is this on trunk? Thanks, > transient unit test failure

[jira] [Comment Edited] (KAFKA-1539) Due to OS caching Kafka might loose offset files which causes full reset of data

2014-07-14 Thread Dmitry Bugaychenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14060456#comment-14060456 ] Dmitry Bugaychenko edited comment on KAFKA-1539 at 7/14/14 8:58 AM:

[jira] [Commented] (KAFKA-1539) Due to OS caching Kafka might loose offset files which causes full reset of data

2014-07-14 Thread Dmitry Bugaychenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14060456#comment-14060456 ] Dmitry Bugaychenko commented on KAFKA-1539: --- This is not about log files themsel

[jira] [Commented] (KAFKA-1539) Due to OS caching Kafka might loose offset files which causes full reset of data

2014-07-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14060413#comment-14060413 ] Joe Stein commented on KAFKA-1539: -- Did you have the log.flush.interval.messages == 1 whe

[jira] [Created] (KAFKA-1539) Due to OS caching Kafka might loose offset files which causes full reset of data

2014-07-14 Thread Dmitry Bugaychenko (JIRA)
Dmitry Bugaychenko created KAFKA-1539: - Summary: Due to OS caching Kafka might loose offset files which causes full reset of data Key: KAFKA-1539 URL: https://issues.apache.org/jira/browse/KAFKA-1539