Discount code for kafka summit SF 2018

Hi folks, Was wondering if this list has a discount code for kafka summit -San francisco 2018. I know there was one last year, so just wanted to check! Thanks! aarti

Re: java.lang.IllegalStateException: Correlation id for response () does not match request ()

https://issues.apache.org/jira/browse/KAFKA-4669?focusedCommentId=16271727&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-16271727 Can we reopen this issue ? We saw this on the consumer in production today. We are on 0.11.01 ERROR c.v.v.h.m.k.KafkaEventConsumerDeleg

Re: [DISCUSS] KIP-105: Addition of Record Level for Sensors

s > it will be added to? Does it contain any parameters? > > > Guozhang > > > > On Sun, Jan 1, 2017 at 5:31 AM, Eno Thereska > wrote: > > > Thanks for starting the discussion on these KIPs Aarti. > > > > Eno > > > > On Sunday, January 1, 201

Re: [DISCUSS] KIP-104: Granular Sensors for Streams

l be the > default values for those added parameters in the existing API functions? > > > > Guozhang > > > On Fri, Dec 30, 2016 at 8:26 PM, Aarti Gupta > wrote: > > > Hi all, > > > > I would like to start the discussion on KIP-104: Granular Sensors

Re: [DISCUSS] KIP-105: Addition of Record Level for Sensors

i.apache.org/confluence/display/KAFKA/KIP-105%3A+Addition+of+Record+Level+for+Sensors > > ? > > > > On Fri, Dec 30, 2016 at 8:31 PM, Aarti Gupta > wrote: > > > > > Hi all, > > > > > > I would like to start the discussion on KIP-105: Addition

Re: Please add my wiki username contributor permission list

Thanks Ewen! I was able to edit the page and add two new KIPs Aarti On Fri, Dec 30, 2016 at 12:47 PM, Ewen Cheslack-Postava wrote: > I've granted you permissions, you should now be able to edit the main KIP > page and add a new KIP. > > -Ewen > > On Fri, Dec 30, 2016

[DISCUSS] KIP-105: Addition of Record Level for Sensors

Hi all, I would like to start the discussion on KIP-105: Addition of Record Level for Sensors *https://cwiki.apache.org/confluence/pages/viewpage.action? * *pageId=67636483* Looking forward to your feedback. Thanks, Aarti

[DISCUSS] KIP-104: Granular Sensors for Streams

Hi all, I would like to start the discussion on KIP-104: Granular Sensors for Streams *https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=67636480

Please add my wiki username contributor permission list

Hey devs, My jira username is aartigupta and my wiki username happens to be aartiguptaa (not sure how that happened) I already have JIRA access, but no permissions to edit the KIP wiki. https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals Can someone grant my username

[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 metr

[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 gran

[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:5

[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

[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 (

[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

[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 lev

[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 h

[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 metr

[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 descriptio

[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 metr

[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. testBrokerFail

Re: Please add me to the contributor list

Thanks! looking forward to contributing -aarti On Fri, Feb 19, 2016 at 2:06 PM, Jun Rao wrote: > Aarti, > > Thanks for your interest. Added to you to the contributor list. > > Jun > > On Fri, Feb 19, 2016 at 2:03 PM, Aarti Gupta > wrote: > > > Hi folks! >

[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

[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. testBrokerFail

Please add me to the contributor list

Hi folks! Want to start contributing to Kafka, found some newbie JIRAs such as https://issues.apache.org/jira/browse/KAFKA-3118 Please, can I be added to the contributor list? My jira username is aartigupta Thanks! aarti

[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

Re: [VOTE] KIP-41: Consumer Max Records

+1, this seems to be the best non intrusive option, and allows us to process a known amount of message on each poll. We can handle consumer memory footprints in a separate KIP. -Thanks aarti On Wed, Jan 13, 2016 at 3:18 PM, Jason Gustafson wrote: > Hi All, > > I'd like to open up the vote on K

Re: KIP-41: KafkaConsumer Max Records

Hi Jason, +1 on the idea of adding max.poll.bytes as an optional configuration (default set to -1, would mean that the setting does not come into play) The pre-fetching optimization, (pre fetch again only those partitions with no retained data), seems slightly better(same as what we have in produ

Re: KIP-41: KafkaConsumer Max Records

@Jason, (apologies, got your name wrong the first time round) On Thu, Jan 7, 2016 at 5:15 PM, Aarti Gupta wrote: > Hi Json, > > I am concerned about how many records can be prefetched into consumer > memory. > Currently we control the maximum number of bytes per topic and partiti

Re: KIP-41: KafkaConsumer Max Records

Hi Json, I am concerned about how many records can be prefetched into consumer memory. Currently we control the maximum number of bytes per topic and partition by setting fetch.message.max.bytes The max.partition.fetch.bytes = #no of partitions * fetch.message.max.bytes However, partitions can be

[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

[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:4

[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 whi

[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

[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, pl

[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

[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

[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

[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

[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 wan

[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,

[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

[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

[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

[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

[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.h

[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