neeraj created KAFKA-8207: ----------------------------- Summary: 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
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 (v7.6.3#76005)