You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2020/05/06 18:48:00 UTC

[jira] [Resolved] (KAFKA-8207) StickyPartitionAssignor for KStream

     [ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Sophie Blee-Goldman resolved KAFKA-8207.
----------------------------------------
    Resolution: Not A Problem

Closing this as "Not a Problem" as the partition assignor can't be overriden by design. The assignment of tasks to clients should be sticky, in particular it should not return the exact same assignment in the case of a simple restart as mentioned below.

> StickyPartitionAssignor for KStream
> -----------------------------------
>
>                 Key: KAFKA-8207
>                 URL: https://issues.apache.org/jira/browse/KAFKA-8207
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>    Affects Versions: 2.0.0
>            Reporter: neeraj
>            Priority: Major
>
> In KStreams I am not able to give a sticky partition assignor or my custom partition assignor.
> Overriding the property while building stream does not work
> streams props.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG, CustomAssignor.class.getName());
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)