[jira] [Updated] (KAFKA-1474) Fix a document typo "in in" --> "in"

[ https://issues.apache.org/jira/browse/KAFKA-1474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengwei Yang updated KAFKA-1474: - Status: Patch Available (was: Open) > Fix a document typo "in in" --> "in" > ---

[jira] [Created] (KAFKA-1474) Fix a document typo "in in" --> "in"

Chengwei Yang created KAFKA-1474: Summary: Fix a document typo "in in" --> "in" Key: KAFKA-1474 URL: https://issues.apache.org/jira/browse/KAFKA-1474 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-1474) Fix a document typo "in in" --> "in"

[ https://issues.apache.org/jira/browse/KAFKA-1474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengwei Yang updated KAFKA-1474: - Attachment: KAFKA-1474.patch The patch to fix this typo > Fix a document typo "in in" --> "in" >

[jira] [Commented] (KAFKA-1466) Kafka server is hung after throwing "Attempt to swap the new high watermark file with the old one failed"

[ https://issues.apache.org/jira/browse/KAFKA-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14012053#comment-14012053 ] Jun Rao commented on KAFKA-1466: Was the broker wrapped in some container? System.exit() w

Re: Review Request 21616: Patch for KAFKA-924

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21616/#review44232 --- There seems to be a bunch of white space changes. Could we remove th

[jira] [Commented] (KAFKA-1466) Kafka server is hung after throwing "Attempt to swap the new high watermark file with the old one failed"

[ https://issues.apache.org/jira/browse/KAFKA-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011913#comment-14011913 ] Arup Malakar commented on KAFKA-1466: - [~jkreps] I am running kafka-0.8 so it would be

[jira] [Commented] (KAFKA-924) Specify console consumer properties via a single --property command line parameter

[ https://issues.apache.org/jira/browse/KAFKA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011903#comment-14011903 ] Sriharsha Chintalapani commented on KAFKA-924: -- [~junrao] [~nehanarkhede] This

[jira] [Updated] (KAFKA-924) Specify console consumer properties via a single --property command line parameter

[ https://issues.apache.org/jira/browse/KAFKA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-924: - Attachment: KAFKA-924_2014-05-28_17:47:53.patch > Specify console consumer propert

[jira] [Commented] (KAFKA-924) Specify console consumer properties via a single --property command line parameter

[ https://issues.apache.org/jira/browse/KAFKA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011901#comment-14011901 ] Sriharsha Chintalapani commented on KAFKA-924: -- Updated reviewboard https://re

Re: Review Request 21616: Patch for KAFKA-924

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21616/ --- (Updated May 29, 2014, 12:47 a.m.) Review request for kafka. Bugs: KAFKA-924

Re: Review Request 21899: Patch for KAFKA-1382

> On May 27, 2014, 9:10 p.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/utils/ZkUtils.scala, line 390 > > > > > > This is a generic API for conditional updates. Logic specific to Kafka > > shouldn't go here.

[jira] [Commented] (KAFKA-1468) Improve perf tests

[ https://issues.apache.org/jira/browse/KAFKA-1468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011798#comment-14011798 ] Jay Kreps commented on KAFKA-1468: -- Updated reviewboard https://reviews.apache.org/r/2187

[jira] [Updated] (KAFKA-1468) Improve perf tests

[ https://issues.apache.org/jira/browse/KAFKA-1468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1468: - Attachment: KAFKA-1468_2014-05-28_16:15:01.patch > Improve perf tests > -- > >

Re: Review Request 21878: KAFKA-1468: Misc. improvements to test scripts from benchmarking

> On May 28, 2014, 1:38 a.m., Jun Rao wrote: > > The target throughput is in records/sec. This is a bit poorly documented. My thinking was that we should separate out the system test logic from the old producer performance test and replace it with this one. When we do that we should move the

Re: Review Request 21878: Patch for KAFKA-1468

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21878/ --- (Updated May 28, 2014, 11:15 p.m.) Review request for kafka. Summary (updated

[jira] [Commented] (KAFKA-1466) Kafka server is hung after throwing "Attempt to swap the new high watermark file with the old one failed"

[ https://issues.apache.org/jira/browse/KAFKA-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011750#comment-14011750 ] Jay Kreps commented on KAFKA-1466: -- Is it possible you were out of disk space? Here is t

[jira] [Comment Edited] (KAFKA-1466) Kafka server is hung after throwing "Attempt to swap the new high watermark file with the old one failed"

[ https://issues.apache.org/jira/browse/KAFKA-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011750#comment-14011750 ] Jay Kreps edited comment on KAFKA-1466 at 5/28/14 10:53 PM: Is

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011735#comment-14011735 ] Jay Kreps commented on KAFKA-1316: -- [~guozhang] I think you are describing the case where

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011641#comment-14011641 ] Guozhang Wang commented on KAFKA-1316: -- [~jkreps] I understand that we are just addin

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011604#comment-14011604 ] Jay Kreps commented on KAFKA-1316: -- [~junrao] NetworkClient is #4, it depends on 1,2,3. S

[jira] [Updated] (KAFKA-1466) Kafka server is hung after throwing "Attempt to swap the new high watermark file with the old one failed"

[ https://issues.apache.org/jira/browse/KAFKA-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arup Malakar updated KAFKA-1466: Attachment: kafka.log.1 [~jjkoshy] Some more info: 1. The topic we use for actual prod messages is

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011551#comment-14011551 ] Guozhang Wang commented on KAFKA-1316: -- Here are some more thoughts: If we are going

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011549#comment-14011549 ] Jun Rao commented on KAFKA-1316: Jay, those make sense. Since NetworkClient is in #4, do y

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011513#comment-14011513 ] Jay Kreps commented on KAFKA-1316: -- [~junrao] Here is how I think of the boundary of resp

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011498#comment-14011498 ] Jun Rao commented on KAFKA-1316: A few thoughts on this. 1. NetworkClient wraps the logic

Jenkins build is back to normal : Kafka-trunk #193

See

[jira] [Commented] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011446#comment-14011446 ] Neha Narkhede commented on KAFKA-1438: -- [~sriharsha] I think you need to do the follo

Producer Side Metric Details

Hi Kafka Group, I need to get following metrics from the producer side. I am able to get following metric using the ProducerTopicMetrics class per minute. messageRate byteRate droppedMessageRate I would like to know how to get above metric per topic per partition. Also, how do I get count of num

[jira] [Commented] (KAFKA-924) Specify console consumer properties via a single --property command line parameter

[ https://issues.apache.org/jira/browse/KAFKA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011404#comment-14011404 ] Jun Rao commented on KAFKA-924: --- That's also possible. We will have to figure out how to pass

Re: Review Request 21899: Patch for KAFKA-1382

> On May 27, 2014, 9:10 p.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/utils/ZkUtils.scala, line 390 > > > > > > This is a generic API for conditional updates. Logic specific to Kafka > > shouldn't go here.

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1472: - Labels: newbie (was: ) > Add the compression ratio metrics in the new producer > ---

[jira] [Commented] (KAFKA-924) Specify console consumer properties via a single --property command line parameter

[ https://issues.apache.org/jira/browse/KAFKA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011314#comment-14011314 ] Neha Narkhede commented on KAFKA-924: - [~junrao] Thanks for catching that. However, is

[jira] [Commented] (KAFKA-924) Specify console consumer properties via a single --property command line parameter

[ https://issues.apache.org/jira/browse/KAFKA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011292#comment-14011292 ] Jun Rao commented on KAFKA-924: --- All system tests are under system_test/. You can read the RE

[jira] [Created] (KAFKA-1473) transient unit test failure in testRequestHandlingDuringDeleteTopic

Jun Rao created KAFKA-1473: -- Summary: transient unit test failure in testRequestHandlingDuringDeleteTopic Key: KAFKA-1473 URL: https://issues.apache.org/jira/browse/KAFKA-1473 Project: Kafka Issue

[jira] [Commented] (KAFKA-1473) transient unit test failure in testRequestHandlingDuringDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011279#comment-14011279 ] Jun Rao commented on KAFKA-1473: I think we probably need to make sure the metadata cache

[jira] [Commented] (KAFKA-924) Specify console consumer properties via a single --property command line parameter

[ https://issues.apache.org/jira/browse/KAFKA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011268#comment-14011268 ] Sriharsha Chintalapani commented on KAFKA-924: -- Thanks [~junrao] . Will send a

[jira] [Commented] (KAFKA-1465) kafka-reassign-partitions.sh fails when topic name contains dash/hyphen

[ https://issues.apache.org/jira/browse/KAFKA-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011264#comment-14011264 ] Jun Rao commented on KAFKA-1465: Could you try this on 0.8.1.1? The reassignment tool is o

[jira] [Commented] (KAFKA-924) Specify console consumer properties via a single --property command line parameter

[ https://issues.apache.org/jira/browse/KAFKA-924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011261#comment-14011261 ] Jun Rao commented on KAFKA-924: --- Thanks for the patch. This seems to have broken our system t

[jira] [Updated] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1438: -- Attachment: KAFKA-1438_2014-05-28_08:40:22.patch > Migrate kafka client tools >

Re: Review Request 21865: Patch for KAFKA-1438

> On May 28, 2014, 12:27 a.m., Guozhang Wang wrote: > > I get the same error as Neha on kafka-run-class.sh, could you double check > > if there is anything wrong with that diff? > > Sriharsha Chintalapani wrote: > I did a git diff against origin/trunk and applied as a patch but the one > u

Re: Review Request 21865: Patch for KAFKA-1438

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21865/ --- (Updated May 28, 2014, 3:40 p.m.) Review request for kafka. Bugs: KAFKA-1438

[jira] [Commented] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011218#comment-14011218 ] Sriharsha Chintalapani commented on KAFKA-1438: --- Updated reviewboard https:/

[jira] [Updated] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1438: -- Attachment: KAFKA-1438_2014-05-28_08:36:28.patch > Migrate kafka client tools >

[jira] [Commented] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011213#comment-14011213 ] Sriharsha Chintalapani commented on KAFKA-1438: --- Updated reviewboard https:/

Re: Review Request 21977: Patch for KAFKA-1438

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21977/ --- (Updated May 28, 2014, 3:36 p.m.) Review request for kafka. Bugs: KAFKA-1438

[jira] [Commented] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011206#comment-14011206 ] Sriharsha Chintalapani commented on KAFKA-1438: --- Updated reviewboard https:/

[jira] [Updated] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1438: -- Attachment: KAFKA-1438_2014-05-28_08:32:46.patch > Migrate kafka client tools >

Re: Review Request 21977: Patch for KAFKA-1438

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21977/ --- (Updated May 28, 2014, 3:32 p.m.) Review request for kafka. Bugs: KAFKA-1438

Review Request 21977: Patch for KAFKA-1438

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21977/ --- Review request for kafka. Bugs: KAFKA-1438 https://issues.apache.org/jira/b

[jira] [Updated] (KAFKA-1465) kafka-reassign-partitions.sh fails when topic name contains dash/hyphen

[ https://issues.apache.org/jira/browse/KAFKA-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Muraru updated KAFKA-1465: - Description: {{./bin/kafka-reassign-partitions.sh --topics-to-move-json-file ~/rebalance-topic.j

[jira] [Commented] (KAFKA-1465) kafka-reassign-partitions.sh fails when topic name contains dash/hyphen

[ https://issues.apache.org/jira/browse/KAFKA-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011125#comment-14011125 ] Adrian Muraru commented on KAFKA-1465: -- [~junrao] Updated the description with the js

Re: Review Request 21865: Patch for KAFKA-1438

> On May 28, 2014, 12:27 a.m., Guozhang Wang wrote: > > I get the same error as Neha on kafka-run-class.sh, could you double check > > if there is anything wrong with that diff? I did a git diff against origin/trunk and applied as a patch but the one uploaded to reviewboard having issue. I'll