[jira] [Comment Edited] (KAFKA-1642) [Java New Producer Kafka Trunk] CPU Usage Spike to 100% when network connection is lost

2014-12-08 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14239063#comment-14239063 ] Bhavesh Mistry edited comment on KAFKA-1642 at 12/9/14 6:53 AM:

[jira] [Commented] (KAFKA-1642) [Java New Producer Kafka Trunk] CPU Usage Spike to 100% when network connection is lost

2014-12-08 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14239063#comment-14239063 ] Bhavesh Mistry commented on KAFKA-1642: --- [~stevenz3wu], 0.8.2 is very well tested a

[jira] [Commented] (KAFKA-1810) Add IP Filtering / Whitelists-Blacklists

2014-12-08 Thread Jeff Holoman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14239020#comment-14239020 ] Jeff Holoman commented on KAFKA-1810: - [~nehanarkhede] Sure no problem. I had a reque

Re: controller conflict

2014-12-08 Thread Neha Narkhede
It's hard to say without any details. But you are free to try 0.8.2-beta as both of those JIRAs should be fixed in this version. On Mon, Dec 8, 2014 at 2:29 PM, Kane Kim wrote: > Hello, > > We are using kafka 0.8.1.1 and hit this bug - 1029, /controller > ephemeral node conflict. Is it supposed

[jira] [Commented] (KAFKA-1806) broker can still expose uncommitted data to a consumer

2014-12-08 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14238987#comment-14238987 ] Neha Narkhede commented on KAFKA-1806: -- [~lokeshbirla] Please can you provide the ste

[jira] [Commented] (KAFKA-1810) Add IP Filtering / Whitelists-Blacklists

2014-12-08 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14238985#comment-14238985 ] Neha Narkhede commented on KAFKA-1810: -- [~jholoman] Not sure I understood what you ar

[jira] [Updated] (KAFKA-1811) ensuring registered broker host:port is unique

2014-12-08 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1811: - Labels: newbie (was: ) > ensuring registered broker host:port is unique > ---

[jira] [Updated] (KAFKA-1812) Allow IpV6 in configuration with parseCsvMap

2014-12-08 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1812: - Labels: newbie (was: ) > Allow IpV6 in configuration with parseCsvMap >

[jira] [Created] (KAFKA-1812) Allow IpV6 in configuration with parseCsvMap

2014-12-08 Thread Jeff Holoman (JIRA)
Jeff Holoman created KAFKA-1812: --- Summary: Allow IpV6 in configuration with parseCsvMap Key: KAFKA-1812 URL: https://issues.apache.org/jira/browse/KAFKA-1812 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-1811) ensuring registered broker host:port is unique

2014-12-08 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-1811: -- Summary: ensuring registered broker host:port is unique Key: KAFKA-1811 URL: https://issues.apache.org/jira/browse/KAFKA-1811 Project: Kafka Issue Type: Improvement

Re: [DISCUSSION] adding the serializer api back to the new java producer

2014-12-08 Thread Sriram Subramanian
Thank you Jay. I agree with the issue that you point w.r.t paired serializers. I also think having mix serialization types is rare. To get the current behavior, one can simply use a ByteArraySerializer. This is best understood by talking with many customers and you seem to have done that. I am conv

[jira] [Commented] (KAFKA-1784) Implement a ConsumerOffsetClient library

2014-12-08 Thread Mayuresh Gharat (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14238736#comment-14238736 ] Mayuresh Gharat commented on KAFKA-1784: Yes. We are planning to do that. Actually

[jira] [Updated] (KAFKA-1784) Implement a ConsumerOffsetClient library

2014-12-08 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1784: - Reviewer: Neha Narkhede Assigning to myself for review since [~jjkoshy] is on vacation. > Impleme

[jira] [Commented] (KAFKA-1784) Implement a ConsumerOffsetClient library

2014-12-08 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14238723#comment-14238723 ] Neha Narkhede commented on KAFKA-1784: -- [~mgharat] Thanks for the patch. Can you add

[jira] [Updated] (KAFKA-1797) add the serializer/deserializer api to the new java client

2014-12-08 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1797: - Reviewer: Neha Narkhede > add the serializer/deserializer api to the new java client > ---

[jira] [Commented] (KAFKA-1044) change log4j to slf4j

2014-12-08 Thread Jon Barksdale (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14238611#comment-14238611 ] Jon Barksdale commented on KAFKA-1044: -- As as workaround, you can exclude log4j from

controller conflict

2014-12-08 Thread Kane Kim
Hello, We are using kafka 0.8.1.1 and hit this bug - 1029, /controller ephemeral node conflict. Is it supposed to be fixed or has something to do with 1451? Thanks.

Re: [DISCUSSION] adding the serializer api back to the new java producer

2014-12-08 Thread Jun Rao
Ok, based on all the feedbacks that we have heard, I plan to do the following. 1. Keep the generic api in KAFKA-1797. 2. Add a new constructor in Producer/Consumer that takes the key and the value serializer instance. 3. Have KAFKA-1797 reviewed and checked into 0.8.2 and trunk. This will make it

[jira] [Commented] (KAFKA-1810) Add IP Filtering / Whitelists-Blacklists

2014-12-08 Thread Jeff Holoman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14238179#comment-14238179 ] Jeff Holoman commented on KAFKA-1810: - There was a discussion in KAFKA-1512 regarding

[jira] [Assigned] (KAFKA-1810) Add IP Filtering / Whitelists-Blacklists

2014-12-08 Thread Jeff Holoman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman reassigned KAFKA-1810: --- Assignee: Jeff Holoman (was: Jun Rao) > Add IP Filtering / Whitelists-Blacklists >

[jira] [Updated] (KAFKA-1810) Add IP Filtering / Whitelists-Blacklists

2014-12-08 Thread Jeff Holoman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated KAFKA-1810: Fix Version/s: 0.8.3 > Add IP Filtering / Whitelists-Blacklists > -

[jira] [Created] (KAFKA-1810) Add IP Filtering / Whitelists-Blacklists

2014-12-08 Thread Jeff Holoman (JIRA)
Jeff Holoman created KAFKA-1810: --- Summary: Add IP Filtering / Whitelists-Blacklists Key: KAFKA-1810 URL: https://issues.apache.org/jira/browse/KAFKA-1810 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-1806) broker can still expose uncommitted data to a consumer

2014-12-08 Thread lokesh Birla (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14238136#comment-14238136 ] lokesh Birla commented on KAFKA-1806: - is there any update on this? > broker can stil

[jira] [Commented] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237960#comment-14237960 ] Andrii Biletskyi commented on KAFKA-1775: - Patch is available under parent ticket

[jira] [Reopened] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi reopened KAFKA-1775: - > Re-factor TopicCommand into thew handerAdminMessage call >

[jira] [Reopened] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi reopened KAFKA-1774: - > REPL and Shell Client for Admin Message RQ/RP >

[jira] [Updated] (KAFKA-1802) Add a new type of request for the discovery of the controller

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-1802: Attachment: (was: KAFKA-1802_2014-12-08_12:56:03.patch) > Add a new type of request for

[jira] [Resolved] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi resolved KAFKA-1775. - Resolution: Implemented > Re-factor TopicCommand into thew handerAdminMessage call >

[jira] [Commented] (KAFKA-1802) Add a new type of request for the discovery of the controller

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237954#comment-14237954 ] Andrii Biletskyi commented on KAFKA-1802: - Patch is available under parent ticket

[jira] [Updated] (KAFKA-1802) Add a new type of request for the discovery of the controller

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-1802: Attachment: (was: KAFKA-1802.patch) > Add a new type of request for the discovery of the

[jira] [Resolved] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi resolved KAFKA-1774. - Resolution: Implemented > REPL and Shell Client for Admin Message RQ/RP >

[jira] [Issue Comment Deleted] (KAFKA-1802) Add a new type of request for the discovery of the controller

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-1802: Comment: was deleted (was: Updated reviewboard https://reviews.apache.org/r/28643/diff/ aga

[jira] [Issue Comment Deleted] (KAFKA-1802) Add a new type of request for the discovery of the controller

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-1802: Comment: was deleted (was: Created reviewboard https://reviews.apache.org/r/28643/diff/ aga

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-1772: Attachment: (was: KAFKA-1772.patch) > Add an Admin message type for request response > -

[jira] [Comment Edited] (KAFKA-1772) Add an Admin message type for request response

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14216456#comment-14216456 ] Andrii Biletskyi edited comment on KAFKA-1772 at 12/8/14 3:12 PM: --

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-1772: Attachment: (was: KAFKA-1772_2014-12-02_16:23:26.patch) > Add an Admin message type for

[jira] [Commented] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237951#comment-14237951 ] Andrii Biletskyi commented on KAFKA-1774: - Patch is available under parent ticket

[jira] [Comment Edited] (KAFKA-1694) kafka command line and centralized operations

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237283#comment-14237283 ] Andrii Biletskyi edited comment on KAFKA-1694 at 12/8/14 12:40 PM: -

[jira] [Updated] (KAFKA-1694) kafka command line and centralized operations

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-1694: Attachment: KAFKA-1772_1802_1775_1774_v2.patch > kafka command line and centralized operatio

[jira] [Updated] (KAFKA-1694) kafka command line and centralized operations

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-1694: Attachment: (was: KAFKA-1772_1802_1775_1774.patch) > kafka command line and centralized

[jira] [Comment Edited] (KAFKA-1792) change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments

2014-12-08 Thread Dmitry Pekar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237796#comment-14237796 ] Dmitry Pekar edited comment on KAFKA-1792 at 12/8/14 11:49 AM: -

[jira] [Comment Edited] (KAFKA-1792) change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments

2014-12-08 Thread Dmitry Pekar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237796#comment-14237796 ] Dmitry Pekar edited comment on KAFKA-1792 at 12/8/14 11:48 AM: -

[jira] [Commented] (KAFKA-1792) change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments

2014-12-08 Thread Dmitry Pekar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237796#comment-14237796 ] Dmitry Pekar commented on KAFKA-1792: - [~nehanarkhede] Thank you for your comments. I'

[jira] [Commented] (KAFKA-1792) change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments

2014-12-08 Thread Dmitry Pekar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237786#comment-14237786 ] Dmitry Pekar commented on KAFKA-1792: - Updated reviewboard https://reviews.apache.org/

[jira] [Updated] (KAFKA-1792) change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments

2014-12-08 Thread Dmitry Pekar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Pekar updated KAFKA-1792: Attachment: KAFKA-1792_2014-12-08_13:42:43.patch > change behavior of --generate to produce assignme

Re: Review Request 28481: Patch for KAFKA-1792

2014-12-08 Thread Dmitry Pekar
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28481/ --- (Updated Dec. 8, 2014, 11:43 a.m.) Review request for kafka. Bugs: KAFKA-1792

[jira] [Updated] (KAFKA-1802) Add a new type of request for the discovery of the controller

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-1802: Attachment: KAFKA-1802_2014-12-08_12:56:03.patch > Add a new type of request for the discove

[jira] [Commented] (KAFKA-1802) Add a new type of request for the discovery of the controller

2014-12-08 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237754#comment-14237754 ] Andrii Biletskyi commented on KAFKA-1802: - Updated reviewboard https://reviews.apa

Re: Review Request 28643: Patch for KAFKA-1802

2014-12-08 Thread Andrii Biletskyi
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28643/ --- (Updated Dec. 8, 2014, 10:56 a.m.) Review request for kafka. Bugs: KAFKA-1802

[jira] [Commented] (KAFKA-1650) Mirror Maker could lose data on unclean shutdown.

2014-12-08 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14237679#comment-14237679 ] Jiangjie Qin commented on KAFKA-1650: - Updated reviewboard https://reviews.apache.org/

[jira] [Updated] (KAFKA-1650) Mirror Maker could lose data on unclean shutdown.

2014-12-08 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1650: Attachment: KAFKA-1650_2014-12-08_01:36:01.patch > Mirror Maker could lose data on unclean shutdown.

Re: Review Request 25995: Patch for KAFKA-1650

2014-12-08 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25995/ --- (Updated Dec. 8, 2014, 9:36 a.m.) Review request for kafka. Bugs: KAFKA-1650