Justinwins commented on PR #8656: URL: https://github.com/apache/kafka/pull/8656#issuecomment-1161331513
> In my case follower doesn't update configuration because **changed** flag keeps **false** value. Neither task count has been changed nor task configs. https://github.com/savinov/kafka/blob/3.1.0-KAFKA-9981/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java#L1571 https://github.com/savinov/kafka/blob/3.1.0-KAFKA-9981/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java#L1577 > > I forget to mention: I want to distribute workload between two or more mm2 instances without any topic/partition changes. This patch isn't enough to do that. @savinov @denglinfan how do you finally work around this issue ? I come into the same situation ,too. thanks a lot for replying -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
