Skip to main content

Re: KafkaStreams GroupBy with new key. Can I skip repartition?

Guozhang
The ticket definitely describes what I'm trying to achieve.
And should I be hopeful with the fact it's in progress? :)
Thanks for pointing that out.
Murilo

On Fri, Feb 28, 2020 at 2:57 PM Guozhang Wang <wangguoz@gmail.com> wrote:

> Hi Murilo,
>
> Would this be helping your case?
> https://issues.apache.org/jira/browse/KAFKA-4835
>
>
> Guozhang
>
> On Fri, Feb 28, 2020 at 7:01 AM Murilo Tavares <murilofla@gmail.com>
> wrote:
>
> > Hi
> > I am currently doing a simple KTable groupby().aggregate() in
> KafkaStreams.
> > In the groupBy I do need to select a new key, but I know for sure that
> the
> > new key would still fall in the same partition. Because of this, I
> believe
> > the repartition would not be necessary, but my question is: is it
> possible
> > to do a groupBy, changing the key, and tell KafkaStreams to not create
> the
> > repartition topic?
> > Thanks
> > Murilo
> >
>
>
> --
> -- Guozhang
>

Comments