[jira] [Updated] (KAFKA-3715) Higher granularity streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-3715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta updated KAFKA-3715: --- Assignee: Eno Thereska (was: aarti gupta) > Higher granularity streams metrics > ---

[jira] [Commented] (KAFKA-3715) Higher granularity streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-3715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15703705#comment-15703705 ] aarti gupta commented on KAFKA-3715: [~enothereska] go for it! > Higher granularity s

[jira] [Comment Edited] (KAFKA-3811) Introduce Kafka Streams metrics recording levels

[ https://issues.apache.org/jira/browse/KAFKA-3811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326855#comment-15326855 ] aarti gupta edited comment on KAFKA-3811 at 6/13/16 5:51 AM: -

[jira] [Commented] (KAFKA-3811) Introduce Kafka Streams metrics recording levels

[ https://issues.apache.org/jira/browse/KAFKA-3811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326855#comment-15326855 ] aarti gupta commented on KAFKA-3811: Yes indeed, as per http://www.brendangregg.com/b

[jira] [Commented] (KAFKA-3811) Introduce Kafka Streams metrics recording levels

[ https://issues.apache.org/jira/browse/KAFKA-3811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15324760#comment-15324760 ] aarti gupta commented on KAFKA-3811: >>Make the metrics lower overhead (this is an iss

[jira] [Commented] (KAFKA-3811) Introduce Kafka Streams metrics recording levels

[ https://issues.apache.org/jira/browse/KAFKA-3811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15324755#comment-15324755 ] aarti gupta commented on KAFKA-3811: [~gfodor] Can you please share and outline the p

[jira] [Assigned] (KAFKA-3811) Introduce Kafka Streams metrics recording levels

[ https://issues.apache.org/jira/browse/KAFKA-3811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta reassigned KAFKA-3811: -- Assignee: aarti gupta (was: Guozhang Wang) > Introduce Kafka Streams metrics recording levels

[jira] [Commented] (KAFKA-3811) Introduce Kafka Streams metrics recording levels

[ https://issues.apache.org/jira/browse/KAFKA-3811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323347#comment-15323347 ] aarti gupta commented on KAFKA-3811: Wondering how this relates to https://issues.apac

[jira] [Work started] (KAFKA-3715) Higher granularity streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-3715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3715 started by aarti gupta. -- > Higher granularity streams metrics > --- > >

[jira] [Commented] (KAFKA-3715) Higher granularity streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-3715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286084#comment-15286084 ] aarti gupta commented on KAFKA-3715: @jklukas, Thanks for the clear description, I wou

[jira] [Assigned] (KAFKA-3715) Higher granularity streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-3715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta reassigned KAFKA-3715: -- Assignee: aarti gupta > Higher granularity streams metrics > -

[jira] [Resolved] (KAFKA-3118) Fail test at: ProducerBounceTest. testBrokerFailure

[ https://issues.apache.org/jira/browse/KAFKA-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta resolved KAFKA-3118. Resolution: Cannot Reproduce > Fail test at: ProducerBounceTest. testBrokerFailure > --

[jira] [Commented] (KAFKA-3118) Fail test at: ProducerBounceTest. testBrokerFailure

[ https://issues.apache.org/jira/browse/KAFKA-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15155184#comment-15155184 ] aarti gupta commented on KAFKA-3118: Unable to reproduce on ubuntu, @edwardt Can you g

[jira] [Assigned] (KAFKA-3118) Fail test at: ProducerBounceTest. testBrokerFailure

[ https://issues.apache.org/jira/browse/KAFKA-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta reassigned KAFKA-3118: -- Assignee: aarti gupta (was: Jun Rao) > Fail test at: ProducerBounceTest. testBrokerFailure >

[jira] [Created] (KAFKA-3154) Ability to shard Kafka based cluster

aarti gupta created KAFKA-3154: -- Summary: Ability to shard Kafka based cluster Key: KAFKA-3154 URL: https://issues.apache.org/jira/browse/KAFKA-3154 Project: Kafka Issue Type: Wish Com

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message, consumer.poll(timeout, maxMessageLimit)

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15068708#comment-15068708 ] aarti gupta commented on KAFKA-3007: Sounds good, will keep an eye out for the KIP >

[jira] [Comment Edited] (KAFKA-3007) new Consumer should expose mechanism to fetch single message, consumer.poll(timeout, maxMessageLimit)

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062996#comment-15062996 ] aarti gupta edited comment on KAFKA-3007 at 12/17/15 10:44 PM: -

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062996#comment-15062996 ] aarti gupta commented on KAFKA-3007: The concern is, that in the scenario in which I h

[jira] [Updated] (KAFKA-3007) new Consumer should expose mechanism to fetch single message, consumer.poll(timeout, maxMessageLimit)

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta updated KAFKA-3007: --- Summary: new Consumer should expose mechanism to fetch single message, consumer.poll(timeout, maxMessa

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062904#comment-15062904 ] aarti gupta commented on KAFKA-3007: Is this on the dev mailing list? If so, please ca

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062742#comment-15062742 ] aarti gupta commented on KAFKA-3007: Can we expose the following private api as a publ

[jira] [Created] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

aarti gupta created KAFKA-3007: -- Summary: new Consumer should expose mechanism to fetch single message Key: KAFKA-3007 URL: https://issues.apache.org/jira/browse/KAFKA-3007 Project: Kafka Issu

[jira] [Commented] (KAFKA-1658) Overriding #of partitions per topic, does not take effect

[ https://issues.apache.org/jira/browse/KAFKA-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154059#comment-14154059 ] aarti gupta commented on KAFKA-1658: Is there a way (programatic or otherwise) to set

[jira] [Created] (KAFKA-1658) Overriding #of partitions per topic, does not take effect

aarti gupta created KAFKA-1658: -- Summary: Overriding #of partitions per topic, does not take effect Key: KAFKA-1658 URL: https://issues.apache.org/jira/browse/KAFKA-1658 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-1657) Fetch request using Simple consumer fails due to failed due to Leader not local for partition

[ https://issues.apache.org/jira/browse/KAFKA-1657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14151952#comment-14151952 ] aarti gupta commented on KAFKA-1657: To elaborate on the expected usage. I want to sp

[jira] [Created] (KAFKA-1657) Fetch request using Simple consumer fails due to failed due to Leader not local for partition

aarti gupta created KAFKA-1657: -- Summary: Fetch request using Simple consumer fails due to failed due to Leader not local for partition Key: KAFKA-1657 URL: https://issues.apache.org/jira/browse/KAFKA-1657

[jira] [Commented] (KAFKA-1632) No such method error on KafkaStream.head

[ https://issues.apache.org/jira/browse/KAFKA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133345#comment-14133345 ] aarti gupta commented on KAFKA-1632: Agreed, so to process a single message, one would

[jira] [Updated] (KAFKA-1632) No such method error on KafkaStream.head

[ https://issues.apache.org/jira/browse/KAFKA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta updated KAFKA-1632: --- Description: \The following error is thrown, (when I call KafkaStream.head(), as shown in the code sn

[jira] [Commented] (KAFKA-1632) No such method error on KafkaStream.head

[ https://issues.apache.org/jira/browse/KAFKA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14132601#comment-14132601 ] aarti gupta commented on KAFKA-1632: I also have a failed attempt of implementing non

[jira] [Updated] (KAFKA-1632) No such method error on KafkaStream.head

[ https://issues.apache.org/jira/browse/KAFKA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta updated KAFKA-1632: --- Description: \The following error is thrown, (when I call KafkaStream.head(), as shown in the code sn

[jira] [Created] (KAFKA-1632) No such method error on KafkaStream.head

aarti gupta created KAFKA-1632: -- Summary: No such method error on KafkaStream.head Key: KAFKA-1632 URL: https://issues.apache.org/jira/browse/KAFKA-1632 Project: Kafka Issue Type: Bug Affect

[jira] [Updated] (KAFKA-1632) No such method error on KafkaStream.head

[ https://issues.apache.org/jira/browse/KAFKA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta updated KAFKA-1632: --- Priority: Major (was: Critical) > No such method error on KafkaStream.head >

[jira] [Updated] (KAFKA-1632) No such method error on KafkaStream.head

[ https://issues.apache.org/jira/browse/KAFKA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta updated KAFKA-1632: --- Description: \The following error is thrown, (when I call KafkaStream.head(), as shown in the code sn