Re: Review Request 21899: Patch for KAFKA-1382

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21899/#review45246 --- core/src/main/scala/kafka/controller/KafkaController.scala

[jira] [Commented] (KAFKA-1298) Controlled shutdown tool doesn't seem to work out of the box

[ https://issues.apache.org/jira/browse/KAFKA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14026743#comment-14026743 ] Jun Rao commented on KAFKA-1298: Thanks for the followup patch. Committed to trunk.

[jira] [Created] (KAFKA-1487) Missing jars in 0.8.1.1 release

Guozhang Wang created KAFKA-1487: Summary: Missing jars in 0.8.1.1 release Key: KAFKA-1487 URL: https://issues.apache.org/jira/browse/KAFKA-1487 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1487) Missing jars in 0.8.1.1 release

[ https://issues.apache.org/jira/browse/KAFKA-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14026893#comment-14026893 ] Joe Stein commented on KAFKA-1487: -- The test jars didn't make the gradle conversion. If

[jira] [Commented] (KAFKA-1486) Move all request/responses to use schema-utils

[ https://issues.apache.org/jira/browse/KAFKA-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027084#comment-14027084 ] Joel Koshy commented on KAFKA-1486: --- Jun mentioned that some of the work in KAFKA-1462

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

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027085#comment-14027085 ] Neha Narkhede commented on KAFKA-1316: -- 2. Ya, I kind of agree with you. These

[jira] [Resolved] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1382. -- Resolution: Fixed Thanks for the patches, pushed to trunk. Update zkVersion on partition

[jira] [Closed] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1382. Update zkVersion on partition state update failures

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027099#comment-14027099 ] Neha Narkhede commented on KAFKA-1382: -- Oops, I'm sorry, I didn't see Jun's latest

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027110#comment-14027110 ] Sriharsha Chintalapani commented on KAFKA-1382: --- [~nehanarkhede] I am

Build failed in Jenkins: Kafka-trunk #203

See https://builds.apache.org/job/Kafka-trunk/203/changes Changes: [neha.narkhede] KAFKA-1382. Update zkVersion on partition state update failures; reviewed by Neha Narkhede -- [...truncated 350 lines...] kafka.log.LogTest testAsyncDelete PASSED

[jira] [Created] (KAFKA-1488) new metrics for measuring the ratio when the new producer is block for space allocation

Jun Rao created KAFKA-1488: -- Summary: new metrics for measuring the ratio when the new producer is block for space allocation Key: KAFKA-1488 URL: https://issues.apache.org/jira/browse/KAFKA-1488 Project:

Review Request 22446: Patch for KAFKA-1488

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22446/ --- Review request for kafka. Bugs: KAFKA-1488

[jira] [Commented] (KAFKA-1488) new metrics for measuring the ratio when the new producer is block for space allocation

[ https://issues.apache.org/jira/browse/KAFKA-1488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027192#comment-14027192 ] Jun Rao commented on KAFKA-1488: Created reviewboard https://reviews.apache.org/r/22446/

[jira] [Updated] (KAFKA-1488) new metrics for measuring the ratio when the new producer is block for space allocation

[ https://issues.apache.org/jira/browse/KAFKA-1488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1488: --- Attachment: KAFKA-1488.patch new metrics for measuring the ratio when the new producer is block for space

Re: Review Request 22446: Patch for KAFKA-1488

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22446/#review45314 --- Ship it! Minor comment.

Re: Review Request 22446: Patch for KAFKA-1488

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22446/#review45315 --- Ship it! Ship It! - Guozhang Wang On June 10, 2014, 11:15 p.m.,

[jira] [Resolved] (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 ] Jun Rao resolved KAFKA-1472. Resolution: Fixed Thanks for the patch. +1. Committed to trunk with a slight modification of the sensor

Re: Review Request 22446: Patch for KAFKA-1488

On June 10, 2014, 11:35 p.m., Joel Koshy wrote: clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java, line 132 https://reviews.apache.org/r/22446/diff/1/?file=606866#file606866line132 Do we really need super-fine granularity here? i.e., we wouldn't

[jira] [Commented] (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:comment-tabpanelfocusedCommentId=14027247#comment-14027247 ] Dong Lin commented on KAFKA-1472: - Thanks much! Add the compression ratio metrics in the

[jira] [Resolved] (KAFKA-1488) new metrics for measuring the ratio when the new producer is block for space allocation

[ https://issues.apache.org/jira/browse/KAFKA-1488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1488. Resolution: Fixed Fix Version/s: 0.8.2 Thanks for the review. Committed to trunk. new metrics for

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

See https://builds.apache.org/job/Kafka-trunk/204/changes

Review Request 22449: 21937

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22449/ --- Review request for kafka. Bugs: KAFKA-1316

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

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027273#comment-14027273 ] Jay Kreps commented on KAFKA-1316: -- Created reviewboard

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

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1316: - Attachment: KAFKA-1316.patch Refactor Sender --- Key: KAFKA-1316

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

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027276#comment-14027276 ] Jay Kreps commented on KAFKA-1316: -- Uploaded patch that has those new APIs. Refactor

Build failed in Jenkins: Kafka-trunk #205

See https://builds.apache.org/job/Kafka-trunk/205/changes Changes: [junrao] KAFKA-1488; new metrics for measuring the ratio when the new producer is block for space allocation; patched by Jun Rao; reviewed by Guozhang Wang and Joel Koshy --

kafka splunk integration

Hello All, Is there a kafka splunk loader/consumer/subscriber? I read in the powered-by page for kafka, that square outputs kafka logs to splunk. Does anyone know how this is done? thanks, Clay

Re: Review Request 22449: 21937

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22449/#review45331 --- Ship it! Looks great. Suggested minor javadoc fix to be included

[jira] [Work started] (KAFKA-1329) Add metadata fetch and refresh functionality to the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-1329 started by Neha Narkhede. Add metadata fetch and refresh functionality to the consumer

[jira] [Assigned] (KAFKA-1329) Add metadata fetch and refresh functionality to the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-1329: Assignee: Neha Narkhede Add metadata fetch and refresh functionality to the consumer

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

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027406#comment-14027406 ] Neha Narkhede commented on KAFKA-1316: -- Thanks for the updated patch, Jay. I'm +1 on