Re: KIP-408: Add Asynchronous Processing to Kafka Streams

Hi all, just saying. We are migrating to a different discussion thread. (Forgot that the discussion thread's name was incorrect.) Sorry for the confusion. On Mon, Dec 24, 2018 at 7:57 PM Richard Yu wrote: > Sorry, just making a correction. > > Even if we are processing records out of order, we

Re: [DISCUSS] KIP-408: Add Asynchronous Processing to Kafka Streams

Hi all, Just changing the title of the KIP. Discovered it wasn't right. Thats about it. :) On Mon, Dec 24, 2018 at 7:57 PM Richard Yu wrote: > Sorry, just making a correction. > > Even if we are processing records out of order, we will still have to > checkpoint offset ranges. > So it doesn't

Re: [VOTE] KIP-349 Priorities for Source Topics

Hi All, Bumping this thread for more votes https://cwiki.apache.org/confluence/display/KAFKA/KIP-349:+Priorities+for+Source+Topics Cheers, -- Nick

Re: [DISCUSS] KIP-382: MirrorMaker 2.0

Becket, this is great feedback, thanks. > having a reserved character for the topics is probably something worth doing in general Agreed, but we shouldn't make this a requirement for MM2, or else it wouldn't work with older versions of Kafka, complicating adoption, testing etc. In particular,

[jira] [Created] (KAFKA-7769) Illegal batch type class

Asaf Mesika created KAFKA-7769: -- Summary: Illegal batch type class Key: KAFKA-7769 URL: https://issues.apache.org/jira/browse/KAFKA-7769 Project: Kafka Issue Type: Bug Components:

Re: [DISCUSS] : KIP-410: Add metric for request handler thread pool utilization by request type

Hey there Mayuresh, Thanks for the KIP! This will prove to be very useful. I am wondering whether we should opt for the name of ` RequestHandlerPoolUsagePercent`. We seem to use the "Percent" suffix to denote fractions of times in other places - e.g `NetworkProcessorAvgIdlePercent` The average