Re: Review Request 25995: Patch for KAFKA-1650

--- 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

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

[ 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.

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

[ https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237679#comment-14237679 ] Jiangjie Qin commented on KAFKA-1650: - Updated reviewboard

Re: Review Request 28643: Patch for KAFKA-1802

--- 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:

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

[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237754#comment-14237754 ] Andrii Biletskyi commented on KAFKA-1802: - Updated reviewboard

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

[ 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

Re: Review Request 28481: Patch for KAFKA-1792

--- 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:

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237786#comment-14237786 ] Dmitry Pekar commented on KAFKA-1792: - Updated reviewboard

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

[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237796#comment-14237796 ] Dmitry Pekar commented on KAFKA-1792: - [~nehanarkhede] Thank you for your comments.

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

[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237796#comment-14237796 ] Dmitry Pekar edited comment on KAFKA-1792 at 12/8/14 11:48 AM:

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

[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237796#comment-14237796 ] Dmitry Pekar edited comment on KAFKA-1792 at 12/8/14 11:49 AM:

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

[ 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] [Updated] (KAFKA-1694) kafka command line and centralized operations

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237283#comment-14237283 ] Andrii Biletskyi edited comment on KAFKA-1694 at 12/8/14 12:40 PM:

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

[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237951#comment-14237951 ] Andrii Biletskyi commented on KAFKA-1774: - Patch is available under parent ticket

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

[ 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] [Comment Edited] (KAFKA-1772) Add an Admin message type for request response

[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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

[ 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] [Issue Comment Deleted] (KAFKA-1802) Add a new type of request for the discovery of the controller

[ 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/

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

[ 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/

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

[ 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] [Updated] (KAFKA-1802) Add a new type of request for the discovery of the controller

[ 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] [Commented] (KAFKA-1802) Add a new type of request for the discovery of the controller

[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237954#comment-14237954 ] Andrii Biletskyi commented on KAFKA-1802: - Patch is available under parent ticket

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

[ 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] [Updated] (KAFKA-1802) Add a new type of request for the discovery of the controller

[ 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] [Reopened] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

[ 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] [Reopened] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

[ 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] [Commented] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14237960#comment-14237960 ] Andrii Biletskyi commented on KAFKA-1775: - Patch is available under parent ticket

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

[ https://issues.apache.org/jira/browse/KAFKA-1806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14238136#comment-14238136 ] lokesh Birla commented on KAFKA-1806: - is there any update on this? broker can still

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

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

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

[ 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

[ 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] [Commented] (KAFKA-1810) Add IP Filtering / Whitelists-Blacklists

[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14238179#comment-14238179 ] Jeff Holoman commented on KAFKA-1810: - There was a discussion in KAFKA-1512 regarding

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

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

controller conflict

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.

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

[ https://issues.apache.org/jira/browse/KAFKA-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14238611#comment-14238611 ] Jon Barksdale commented on KAFKA-1044: -- As as workaround, you can exclude log4j from

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

[ 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-1784) Implement a ConsumerOffsetClient library

[ https://issues.apache.org/jira/browse/KAFKA-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14238723#comment-14238723 ] Neha Narkhede commented on KAFKA-1784: -- [~mgharat] Thanks for the patch. Can you add

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

[ 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.

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

[ https://issues.apache.org/jira/browse/KAFKA-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14238736#comment-14238736 ] Mayuresh Gharat commented on KAFKA-1784: Yes. We are planning to do that. Actually

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

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

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

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

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

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] [Updated] (KAFKA-1812) Allow IpV6 in configuration with parseCsvMap

[ 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] [Updated] (KAFKA-1811) ensuring registered broker host:port is unique

[ 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] [Commented] (KAFKA-1810) Add IP Filtering / Whitelists-Blacklists

[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14238985#comment-14238985 ] Neha Narkhede commented on KAFKA-1810: -- [~jholoman] Not sure I understood what you

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

[ https://issues.apache.org/jira/browse/KAFKA-1806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14238987#comment-14238987 ] Neha Narkhede commented on KAFKA-1806: -- [~lokeshbirla] Please can you provide the

Re: controller conflict

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 kane.ist...@gmail.com wrote: Hello, We are using kafka 0.8.1.1 and hit this bug - 1029, /controller ephemeral node

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

[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14239020#comment-14239020 ] Jeff Holoman commented on KAFKA-1810: - [~nehanarkhede] Sure no problem. I had a

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

[ https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14239063#comment-14239063 ] Bhavesh Mistry commented on KAFKA-1642: --- [~stevenz3wu], 0.8.2 is very well tested

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

[ https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14239063#comment-14239063 ] Bhavesh Mistry edited comment on KAFKA-1642 at 12/9/14 6:53 AM: