KIP-392 Allow consumers to fetch from closest replica

I was checking the release notes for 2.4.0 and noticed this KIP. Looks pretty awesome, but I didn't see anything about streams in the KIP. I did a quick glance at the code and also didn't see anywhere where the client.rack for the consumer was exposed out to where it could be set from the streams.

Re: Mirrormaker 2.0

I find the best is the README in the source. Look under connect mirror maker directory I believe. Carl On Mon, Dec 23, 2019, 13:57 Sebastian Schmitz < sebastian.schm...@propellerhead.co.nz> wrote: > Hello, > > I'm currently trying to implement the new Kafka 2.4.0 and the new MM2. > > However, it

Re: Please give a link where I can explain myself what this can be ...

Says to create a state store from the result and give it the name count_store so you can reference and use the data later. Carl On Mon, Dec 23, 2019, 12:31 Aurel Sandu wrote: > I'am reading the folowing code : > ... > KTable wordCounts = textLines > .flatMapValues(textLi

Mirror Maker 2 MirrorClient

All: I was tinkering around with the MirrorClient and was curious about the configs. I see that I can use the MirrorMaker config to pull in the same configs that were used to spin up the MM2 cluster. Seeing as MM2 is started with these configs in a property file and it is passed in on command

Deserialization Exception when performing state store operations

I have a state store being built from a stream with a custom set of value serdes. In the stream processing I am able to handle errors appropriately with the exception handler, but if I attempt to do a state store getAll and use the iterator.hasNext() or next() or peek methods, any exceptions in the

Re: Deserialization Exception when performing state store operations

quiel PUIG > > Le mar. 21 avr. 2020 à 04:59, Carl Graving a écrit : > > > I have a state store being built from a stream with a custom set of value > > serdes. In the stream processing I am able to handle errors appropriately > > with the exception handler, but if I atte

Re: Deserialization Exception when performing state store operations

ion, and instead returns a sentinel value that > you > can handle somehow? > > I hope this helps, > Thanks, > -John > > On Mon, Apr 20, 2020, at 21:59, Carl Graving wrote: > > I have a state store being built from a stream with a custom set of value > > serdes.

KSQL in Production

Kafka Collective, Since KSQL came out there is something I have been watching for in the form of a blog post, article, or somewhere, but I have yet to see it. I may have missed it over the last year+, so I figured I would check in and see if anyone has resources. Here are my questions. 1. How