[
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)
