[jira] [Commented] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14607548#comment-14607548 ] Ewen Cheslack-Postava commented on KAFKA-2168: -- This version was committed to

[jira] [Commented] (KAFKA-2291) Documentation Error

[ https://issues.apache.org/jira/browse/KAFKA-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14607541#comment-14607541 ] Anatoli Fomenko commented on KAFKA-2291: Thanks, UTKARSH. > Documentation Error >

Re: Review Request 35231: Address Onur and Jason's comments

> On June 18, 2015, 12:50 a.m., Jason Gustafson wrote: > > core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala, lines > > 229-236 > > > > > > In manual group management, would we expect consumerId and gene

[jira] [Commented] (KAFKA-2306) New producer should emit metrics for buffer exhaustion

[ https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606954#comment-14606954 ] Dong Lin commented on KAFKA-2306: - Created reviewboard https://reviews.apache.org/r/36034/

[jira] [Updated] (KAFKA-2306) New producer should emit metrics for buffer exhaustion

[ https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2306: Status: Patch Available (was: Open) > New producer should emit metrics for buffer exhaustion >

[jira] [Updated] (KAFKA-2306) New producer should emit metrics for buffer exhaustion

[ https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2306: Attachment: KAFKA-2306.patch > New producer should emit metrics for buffer exhaustion >

Review Request 36034: Patch for KAFKA-2306

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

[jira] [Assigned] (KAFKA-2306) New producer should emit metrics for buffer exhaustion

[ https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-2306: --- Assignee: Dong Lin > New producer should emit metrics for buffer exhaustion > ---

[jira] [Created] (KAFKA-2306) New producer should emit metrics for buffer exhaustion

Dong Lin created KAFKA-2306: --- Summary: New producer should emit metrics for buffer exhaustion Key: KAFKA-2306 URL: https://issues.apache.org/jira/browse/KAFKA-2306 Project: Kafka Issue Type: Bug

Jenkins build is back to normal : KafkaPreCommit #133

See

[jira] [Updated] (KAFKA-2291) Documentation Error

[ https://issues.apache.org/jira/browse/KAFKA-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] UTKARSH BHATNAGAR updated KAFKA-2291: - Resolution: Fixed Status: Resolved (was: Patch Available) > Documentation Error >

[jira] [Commented] (KAFKA-2291) Documentation Error

[ https://issues.apache.org/jira/browse/KAFKA-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606898#comment-14606898 ] UTKARSH BHATNAGAR commented on KAFKA-2291: -- LGTM. > Documentation Error > --

[jira] [Updated] (KAFKA-2291) Documentation Error

[ https://issues.apache.org/jira/browse/KAFKA-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] UTKARSH BHATNAGAR updated KAFKA-2291: - Fix Version/s: 0.8.3 Affects Version/s: 0.8.3 Status: Patch Availabl

Build failed in Jenkins: Kafka-trunk #522

See Changes: [wangguoz] KAFKA-2281: avoid unnecessary value copying if logAsString is false; reviewed by Guozhang Wang -- [...truncated 1410 lines...] kafka.log.BrokerCompressionTest > testBrokerSide

[jira] [Commented] (KAFKA-2129) Consumer could make multiple concurrent metadata requests

[ https://issues.apache.org/jira/browse/KAFKA-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606862#comment-14606862 ] Guozhang Wang commented on KAFKA-2129: -- [~timbrooks], sorry for the long-late reply t

[jira] [Commented] (KAFKA-2291) Documentation Error

[ https://issues.apache.org/jira/browse/KAFKA-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606860#comment-14606860 ] Anatoli Fomenko commented on KAFKA-2291: Please review the patch. Thank you. > Do

[jira] [Updated] (KAFKA-2291) Documentation Error

[ https://issues.apache.org/jira/browse/KAFKA-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anatoli Fomenko updated KAFKA-2291: --- Attachment: KAFKA-2291.patch > Documentation Error > --- > > K

[jira] [Created] (KAFKA-2305) Cluster Monitoring and Management UI

Soumyajit Sahu created KAFKA-2305: - Summary: Cluster Monitoring and Management UI Key: KAFKA-2305 URL: https://issues.apache.org/jira/browse/KAFKA-2305 Project: Kafka Issue Type: Wish

[jira] [Updated] (KAFKA-2281) org.apache.kafka.clients.producer.internals.ErrorLoggingCallback holds unnecessary byte[] value

[ https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2281: - Resolution: Fixed Status: Resolved (was: Patch Available) > org.apache.kafka.clients.prod

[jira] [Commented] (KAFKA-2281) org.apache.kafka.clients.producer.internals.ErrorLoggingCallback holds unnecessary byte[] value

[ https://issues.apache.org/jira/browse/KAFKA-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606822#comment-14606822 ] Guozhang Wang commented on KAFKA-2281: -- Thanks for the patch. +1 and committed to tru

Re: Review Request 35231: Address Onur and Jason's comments

> On June 18, 2015, 12:50 a.m., Jason Gustafson wrote: > > core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala, lines > > 229-236 > > > > > > In manual group management, would we expect consumerId and gene

[jira] [Updated] (KAFKA-1740) Merge Offset manager into Coordinator

[ https://issues.apache.org/jira/browse/KAFKA-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1740: - Attachment: KAFKA-1740_2015-06-29_18:44:54.patch > Merge Offset manager into Coordinator > ---

Re: Review Request 35231: Address Onur and Jason's comments

> On June 11, 2015, 5:40 p.m., Onur Karaman wrote: > > core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala, lines > > 229-236 > > > > > > This can happen in two ways: > > 1. An automatic group manageme

[jira] [Commented] (KAFKA-1740) Merge Offset manager into Coordinator

[ https://issues.apache.org/jira/browse/KAFKA-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606820#comment-14606820 ] Guozhang Wang commented on KAFKA-1740: -- Updated reviewboard https://reviews.apache.or

Re: Review Request 35231: Address Onur and Jason's comments

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35231/ --- (Updated June 30, 2015, 1:44 a.m.) Review request for kafka. Summary (updated

[jira] [Commented] (KAFKA-1740) Merge Offset manager into Coordinator

[ https://issues.apache.org/jira/browse/KAFKA-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606795#comment-14606795 ] Guozhang Wang commented on KAFKA-1740: -- Updated reviewboard https://reviews.apache.or

Re: Review Request 35231: Rebased

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35231/ --- (Updated June 30, 2015, 1:21 a.m.) Review request for kafka. Summary (updated

[jira] [Updated] (KAFKA-1740) Merge Offset manager into Coordinator

[ https://issues.apache.org/jira/browse/KAFKA-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1740: - Attachment: KAFKA-1740_2015-06-29_18:21:42.patch > Merge Offset manager into Coordinator > ---

Re: Review Request 33049: Patch for KAFKA-2084

> On June 17, 2015, 4:40 p.m., Joel Koshy wrote: > > core/src/test/scala/integration/kafka/api/QuotasTest.scala, line 142 > > > > > > This is an important test, but this is a bit non-deterministic no? > > i.e., the r

Re: Review Request 35850: Patch for KAFKA-2301

> On June 25, 2015, 1:06 a.m., Ewen Cheslack-Postava wrote: > > Is this what was intended by "deprecate"? I'm not sure there's been serious > > discussion about this yet, but this doesn't really deprecate the command in > > a compatible way -- just changing to ConsumerGroupCommand requires chan

Re: Review Request 33049: Patch for KAFKA-2084

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33049/ --- (Updated June 30, 2015, 12:54 a.m.) Review request for kafka, Joel Koshy and Ju

[jira] [Updated] (KAFKA-2084) byte rate metrics per client ID (producer and consumer)

[ https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya A Auradkar updated KAFKA-2084: - Attachment: KAFKA-2084_2015-06-29_17:53:44.patch > byte rate metrics per client ID (produc

[jira] [Commented] (KAFKA-2084) byte rate metrics per client ID (producer and consumer)

[ https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606760#comment-14606760 ] Aditya A Auradkar commented on KAFKA-2084: -- Updated reviewboard https://reviews.a

Re: Review Request 33049: Patch for KAFKA-2084

> On June 17, 2015, 4:40 p.m., Joel Koshy wrote: > > core/src/main/scala/kafka/server/ClientQuotaMetrics.scala, line 1 > > > > > > Why was MockTime moved from test to main? Because I need to depend on MockTime from cli

Re: Review Request 33049: Patch for KAFKA-2084

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33049/ --- (Updated June 30, 2015, 12:53 a.m.) Review request for kafka, Joel Koshy and Ju

[jira] [Commented] (KAFKA-972) MetadataRequest returns stale list of brokers

[ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606755#comment-14606755 ] Ashish K Singh commented on KAFKA-972: -- Created reviewboard https://reviews.apache.org

[jira] [Updated] (KAFKA-972) MetadataRequest returns stale list of brokers

[ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-972: - Status: Patch Available (was: Open) > MetadataRequest returns stale list of brokers >

[jira] [Updated] (KAFKA-972) MetadataRequest returns stale list of brokers

[ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-972: - Attachment: KAFKA-972.patch > MetadataRequest returns stale list of brokers > -

Review Request 36030: Patch for KAFKA-972

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

[jira] [Updated] (KAFKA-2304) Support enabling JMX in Kafka Vagrantfile

[ https://issues.apache.org/jira/browse/KAFKA-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stevo Slavic updated KAFKA-2304: Status: Patch Available (was: Open) > Support enabling JMX in Kafka Vagrantfile > -

[jira] [Updated] (KAFKA-2304) Support enabling JMX in Kafka Vagrantfile

[ https://issues.apache.org/jira/browse/KAFKA-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stevo Slavic updated KAFKA-2304: Attachment: KAFKA-2304-JMX.patch Attached [^KAFKA-2304-JMX.patch] > Support enabling JMX in Kafka V

[jira] [Created] (KAFKA-2304) Support enabling JMX in Kafka Vagrantfile

Stevo Slavic created KAFKA-2304: --- Summary: Support enabling JMX in Kafka Vagrantfile Key: KAFKA-2304 URL: https://issues.apache.org/jira/browse/KAFKA-2304 Project: Kafka Issue Type: Bug Aff

[jira] [Commented] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606580#comment-14606580 ] Parth Brahmbhatt commented on KAFKA-2210: - [~junrao] Hey sorry for the delay, I wa

[jira] [Updated] (KAFKA-1688) Add authorization interface and naive implementation

[ https://issues.apache.org/jira/browse/KAFKA-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1688: --- Status: Open (was: Patch Available) This is now going to be handled in KAFKA-2210, KAFKA-2211, and KAFKA-2212

[jira] [Commented] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606548#comment-14606548 ] Jun Rao commented on KAFKA-2210: [~parthbhave], are you still working on this jira? Thanks

Re: [VOTE] KIP-23 - Add JSON/CSV output and looping options to ConsumerGroupCommand

+1 Thanks, Jun On Tue, Jun 23, 2015 at 11:15 AM, Ashish Singh wrote: > Hey Guys, > > We had some discussion over mail and in KIP hangout. I will update the RB > with proposed changes. > > > On Sun, Jun 14, 2015 at 10:07 AM, Ashish Singh > wrote: > >> Hi Neha, >> >> Answers inline. >> >> On Th

[jira] [Updated] (KAFKA-2191) Measured rate should not be infinite

[ https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2191: Resolution: Fixed Status: Resolved (was: Patch Available) Merged into KAFKA-2084. > Measured rate

Mirror maker: New Producer error callback

Hi Contributors, Not sure if any enhancement has been thought in this area. File: https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/producer/BaseProducer.scala (Line 44) Currently, in the mirror maker process all async Producer send calls have ErrorLoggingCallback registered. T

[jira] [Commented] (KAFKA-1215) Rack-Aware replica assignment option

[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606043#comment-14606043 ] Allen Wang commented on KAFKA-1215: --- [~junrao] AWS region (for example us-east-1) can be

Re: [DISCUSS] KIP-26 - Add Copycat, a connector framework for data import/export

Seems like discussion has mostly quieted down on this. Any more questions, comments, or discussion? If nobody brings up any other issues, I'll start a vote thread in a day or two. -Ewen On Thu, Jun 25, 2015 at 3:36 PM, Jay Kreps wrote: > We were talking on the call about a logo...so here I pres