Re: Suppress DSL operator in stream api - 2.4.0

What you say makes sense to me. I am not aware of any known bugs, hence, it seems you are hitting some unknown bug. Can you reproduce it reliably? Maybe you can share the code and input data set so we can have a look? Best would be, if we could reproduce it via TopologyTestDriver. -Matthias On

MirrorMaker from Kafka 2.2 does not respect client.id for consumer

Hi all I have a Kafka MirrorMaker 2.2 configuration running. In the consumer.properties file, I have group.id and client.id configured (among other props). When MirrorMaker starts, it seems to ignore the setting for client.id and uses -0 as the client id (also reports so in the consumer config su

Re: Broker shutdown slowdown between 1.1.0 and 2.3.1

Sure thing! Done . On Fri, Nov 22, 2019 at 7:58 AM Ismael Juma wrote: > Can you please file a JIRA? > > Ismael > > On Thu, Nov 21, 2019 at 3:52 PM Nicholas Feinberg > wrote: > > > I've been looking at upgrading my cluster from 1.1.0 to 2.3.1. Wh

Re: Broker shutdown slowdown between 1.1.0 and 2.3.1

Can you please file a JIRA? Ismael On Thu, Nov 21, 2019 at 3:52 PM Nicholas Feinberg wrote: > I've been looking at upgrading my cluster from 1.1.0 to 2.3.1. While > testing, I've noticed that shutting brokers down seems to take consistently > longer on 2.3.1. Specifically, the process of 'creat

Re: Suppress DSL operator in stream api - 2.4.0

Hi Matthias, when we say 2.4.0, we just built the kafka from source and marked it as 2.4.0 for our internal reference. But I have taken latest Kafka 2.3.1 and tested & the issue still persists. pseudo code: .filter((key, value) -> ...) .groupByKey() .windowedBy(TimeWindows.of(Duration.ofMinutes

Re: [EXTERNAL] Kafka upgrade from 0.10 to 2.3.x

Hi Vitalii, About log format, if clients are old ones will start to fail since they couldn't understand the messages. So bump them if you planning upgrade the log format version. Thanks Get Outlook for Android From: Vitalii Stoianov Sen