[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jason Gustafson resolved KAFKA-4106. ------------------------------------ Resolution: Resolved Assignee: Jason Gustafson The requested functionality already exists. > Consumer / add configure method to PartitionAssignor interface > -------------------------------------------------------------- > > Key: KAFKA-4106 > URL: https://issues.apache.org/jira/browse/KAFKA-4106 > Project: Kafka > Issue Type: Improvement > Components: clients, consumer > Affects Versions: 0.10.0.1 > Reporter: Florian Hussonnois > Assignee: Jason Gustafson > Priority: Minor > > Currently, we can implement a custom PartitionAssignor which will forward > user data that will be used during the assignments protocol. For example, > data can be used to implement a rack-aware assignor > However, currently we cannot dynamically configure a PartitionAssignor > instance. > It would be nice to add a method configure(Map<String, Object config) to the > PartitionAssignor interface. Then, this method will be invoked by the > KafkaConsumer on each assignor, as this is do for deserializers. > The code modifications are pretty straight-forward but involve modifying the > public interface PartitionAssignor. Does that mean this JIRA needs a KIP ? > I can contribute to that improvement. -- This message was sent by Atlassian JIRA (v6.3.4#6332)