Re: Kafka Streams Session store performance degradation from 0.10.2.1 to 0.11.0.3

Hi Matthias, I upgraded to 2.0.0 and we're experiencing the same problem. I've posted a new screengrab of a thread profile: https://imgur.com/a/2wncPHw >From our perspective, it appears something happened after 0.10.2.1 that made >the LRU Cache much slower for our use case. What would you reco

Re: Kafka ingestion data not equally distribute among brokers

Hi That is part of the Producer API. For Java see https://kafka.apache.org/20/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html ProducerRecord regards On Tue, Nov 6, 2018 at 5:46 PM Shiuh Rong Yong < shiuhrongy...@cirosolution.com> wrote: > Hi Manoj, > > I am new on Kaf

Re: [VOTE] 2.0.1 RC0

+1 (binding) Checked source build and unit tests. Ran quickstart with source and binary. Thank you for managing the release, Manikumar! Regards, Rajini On Wed, Nov 7, 2018 at 6:18 PM Gwen Shapira wrote: > +1 (binding) > > Checked signatures, build and quickstart. > > Thank you for managing t

Re: [VOTE] 2.0.1 RC0

+1 (binding) Checked source build and unit tests. Ran quickstart with source and binary. Thank you for managing the release, Manikumar! Regards, Rajini On Wed, Nov 7, 2018 at 6:18 PM Gwen Shapira wrote: > +1 (binding) > > Checked signatures, build and quickstart. > > Thank you for managing t

Re: [VOTE] 2.0.1 RC0

+1 (binding) Checked signatures, build and quickstart. Thank you for managing the release, Mani! On Thu, Oct 25, 2018 at 7:29 PM Manikumar wrote: > > Hello Kafka users, developers and client-developers, > > This is the first candidate for release of Apache Kafka 2.0.1. > > This is a bug fix re

Re: Offsets/Lags for global state stores not shown

Thanks for the response. How "low" is the expected low throughput? We are are using GlobalKTables for IQ on several Topics, but with single-digit million unique messages and usually fewer changes per day. Just to verify, for this IQ setup (streams app which only builds a single table to be queried

Support Roadmap

Hi, Do you have a roadmap detailing how long each Kafka version will be supported with bug fixes? We are currently running 1.1.x and given we may need to support this system for a number of years I'd be interested to know what the support period is. Especially given 2.0.x has been released and 2.