rtitioner in some
> > way to specify that we want records to end up in the source partition,
> > without introducing a new
> > parameter.
> >
> > One option would be to just let users pass in a null StreamPartitioner to
> > mean that it should
> > use the sou
led SourceContextPartitioner (or
> something),
> and then users just have to pass in an instance of this. WDYT?
>
> On Thu, Sep 10, 2020 at 8:00 AM Balan k wrote:
>
> >
> > Forgot to add the link
> >
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-
Forgot to add the link
https://cwiki.apache.org/confluence/display/KAFKA/KIP-669%3A+Preserve+Source+Partition+in+Kafka+Streams+from+context
On 2020/09/10 13:40:02, satyanarayan komandur wrote:
> Hi,
>
> I have submitted a new KIP for preserving processor record context partition
> from sou
