[
https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126442#comment-17126442
]
feyman edited comment on KAFKA-9377 at 6/5/20, 6:28 AM:
--------------------------------------------------------
[~bchen225242], I'm very glad to take it and even feel excited since this one
is *a bit unfriendly for beginners*. But I need to take some time to understand
the current logic so maybe more time to finish, hopefully that's fine and won't
block anything.
Thanks!
was (Author: feyman):
[~bchen225242], I'm very glad to take it and even feel excited since this one
is `a bit unfriendly for beginners`. But I need to take some time to understand
the current logic so maybe more time to finish, hopefully that's fine and won't
block anything.
Thanks!
> Refactor StreamsPartitionAssignor Repartition Count logic
> ---------------------------------------------------------
>
> Key: KAFKA-9377
> URL: https://issues.apache.org/jira/browse/KAFKA-9377
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Boyang Chen
> Assignee: feyman
> Priority: Major
>
> The current repartition count uses a big while loop to randomly initialize
> each repartition topic counts, which is error-prone and hard to maintain. A
> more intuitive and robust solution would be doing a DFS search from
> bottom-up, where we initialize all the sink nodes repartition topic counts by
> making sure all their parents are initialized.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
