You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/05/20 18:02:00 UTC

[jira] [Comment Edited] (KAFKA-8207) StickyPartitionAssignor for KStream

    [ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844168#comment-16844168 ] 

Boyang Chen edited comment on KAFKA-8207 at 5/20/19 6:01 PM:
-------------------------------------------------------------

Hey [~neeraj.bhatt] thank you for your interest and thank you [~mjsax] for the explanation! Good news is that we are planning to ship major features for static membership in 2.3, while unfortunately we could get everything in, and progress is tracked here:

https://issues.apache.org/jira/browse/KAFKA-7018

Feel free to be our alpha user in case you are interested :) And grab me (boyang@confluent.io) if there is anything not behaving as expected.


was (Author: bchen225242):
Hey [~neeraj.bhatt] thank you for your interest! Good news is that we are planning to ship major features for static membership in 2.3, while unfortunately we could get everything in, and progress is tracked here:

https://issues.apache.org/jira/browse/KAFKA-7018


Feel free to be our alpha user in case you are interested :) And grab me (boyang@confluent.io) if there is anything not behaving as expected.

> 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
(v7.6.3#76005)