[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-tabpanel&focusedCommentId=14222684#comment-14222684 ] Ewen Cheslack-Postava commented on KAFKA-1642: -- [~Bmis13] I've only taken a q

[jira] [Commented] (KAFKA-1737) Document required ZkSerializer for ZkClient used with AdminUtils

[ https://issues.apache.org/jira/browse/KAFKA-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14222645#comment-14222645 ] Vivek Madani commented on KAFKA-1737: - Thanks Guozhang, I will submit the patch for th

[jira] [Assigned] (KAFKA-1737) Document required ZkSerializer for ZkClient used with AdminUtils

[ https://issues.apache.org/jira/browse/KAFKA-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vivek Madani reassigned KAFKA-1737: --- Assignee: Vivek Madani > Document required ZkSerializer for ZkClient used with AdminUtils > -

[jira] [Commented] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14222627#comment-14222627 ] Ashish Kumar Singh commented on KAFKA-313: -- [~jjkoshy] can you take a look at the

[jira] [Updated] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Kumar Singh updated KAFKA-313: - Attachment: KAFKA-313.1.patch > Add JSON/CSV output and looping options to ConsumerOffsetCh

Re: Review Request 28096: KAFKA-313: Add JSON/CSV output and looping options to ConsumerOffsetChecker

> On Nov. 20, 2014, 4:44 p.m., Gwen Shapira wrote: > > I'm not super-happy about adding "case" statements everywhere. I'm > > wondering if it makes sense to have a private class implementing generic > > "printPartitionInfo" and "printBrokerInfo" and encapsulate the different > > implementation

Re: Review Request 28096: KAFKA-313: Add JSON/CSV output and looping options to ConsumerOffsetChecker

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28096/ --- (Updated Nov. 24, 2014, 3:53 a.m.) Review request for kafka, Gwen Shapira, Jare

[jira] [Commented] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14222622#comment-14222622 ] Jarek Jarcec Cecho commented on KAFKA-1654: --- Thank you [~nehanarkhede] for beari

[jira] [Updated] (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:all-tabpanel ] Bhavesh Mistry updated KAFKA-1642: -- Attachment: 0001-Initial-CPU-Hish-Usage-by-Kafka-FIX-and-Also-fix-CLO.patch Please take look at

[jira] [Reopened] (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:all-tabpanel ] Bhavesh Mistry reopened KAFKA-1642: --- The patch provided does not solve the problem. When you have more than one producer instance, t

[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-tabpanel&focusedCommentId=14222571#comment-14222571 ] Bhavesh Mistry edited comment on KAFKA-1642 at 11/24/14 1:31 AM: ---

[jira] [Commented] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14222559#comment-14222559 ] Neha Narkhede commented on KAFKA-1654: -- Thanks for the patches. Renamed KafkaTest to

[jira] [Updated] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1654: - Resolution: Fixed Status: Resolved (was: Patch Available) > Provide a way to override ser

Re: Review Request 26474: KAFKA-1654 Provide a way to override server configuration from command line

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26474/#review62746 --- Ship it! Ship It! - Neha Narkhede On Nov. 23, 2014, 5:40 p.m., J

Re: Review Request 23702: Patch for KAFKA-1070

> On Nov. 23, 2014, 8:35 p.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/common/GenerateBrokerIdException.scala, line 23 > > > > > > Given InconsistentBrokerIdException, looks like we don't need this. Generate

Re: Review Request 23702: Patch for KAFKA-1070

> On Nov. 23, 2014, 8:35 p.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/server/KafkaConfig.scala, line 78 > > > > > > Why do we need a policy? It looks like we are trying to design the > > automatic broker id

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14222491#comment-14222491 ] Neha Narkhede commented on KAFKA-1070: -- [~sriharsha] Reviewed your latest patch. Post

Re: Review Request 23702: Patch for KAFKA-1070

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23702/#review62737 --- core/src/main/scala/kafka/common/GenerateBrokerIdException.scala

[jira] [Created] (KAFKA-1795) OOME - high level kafka consumer

Umesh Batra created KAFKA-1795: -- Summary: OOME - high level kafka consumer Key: KAFKA-1795 URL: https://issues.apache.org/jira/browse/KAFKA-1795 Project: Kafka Issue Type: Bug Componen

[jira] [Updated] (KAFKA-1795) OOME - high level kafka consumer

[ https://issues.apache.org/jira/browse/KAFKA-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Batra updated KAFKA-1795: --- Description: I am using Kafka High Level Consumer, version kafka_2.8.0 - 0.8.1.1 with zkclient - 0.3

[jira] [Commented] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14222431#comment-14222431 ] Jarek Jarcec Cecho commented on KAFKA-1654: --- Thanks for the good feedback [~neha

[jira] [Updated] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jarek Jarcec Cecho updated KAFKA-1654: -- Attachment: KAFKA-1654.patch > Provide a way to override server configuration from comma

Re: Review Request 26474: KAFKA-1654 Provide a way to override server configuration from command line

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26474/ --- (Updated Nov. 23, 2014, 5:40 p.m.) Review request for kafka and Neha Narkhede.

Kafka 0.8.2 profile / hotspot analysis blog post

http://www.autoletics.com/posts/quick-performance-hotspot-analysis-apache-kafka I didn’t do, this, just a pointer to some interesting info, YMMV. -Jonathan