Re: [PR] KAFKA-16277: AbstractStickyAssignor - Sort owned TopicPartitions by p… [kafka]

2024-02-23 Thread via GitHub
credpath-seek commented on PR #15416: URL: https://github.com/apache/kafka/pull/15416#issuecomment-1962156726 I was going to try to fix the pipeline issue: ``` [Checks API] No suitable checks publisher found. ``` But then I saw it had been attempted and reverted 

Re: [PR] KAFKA-16277: AbstractStickyAssignor - Sort owned TopicPartitions by p… [kafka]

2024-02-23 Thread via GitHub
credpath-seek commented on PR #15416: URL: https://github.com/apache/kafka/pull/15416#issuecomment-1961101177 Thanks for the review @ableegoldman - I have incorporated your suggested changes -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] KAFKA-16277: AbstractStickyAssignor - Sort owned TopicPartitions by p… [kafka]

2024-02-23 Thread via GitHub
credpath-seek commented on code in PR #15416: URL: https://github.com/apache/kafka/pull/15416#discussion_r1500481139 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java: ## @@ -663,6 +663,7 @@ private void assignOwnedPartitions() {

Re: [PR] KAFKA-16277: AbstractStickyAssignor - Sort owned TopicPartitions by p… [kafka]

2024-02-22 Thread via GitHub
ableegoldman commented on code in PR #15416: URL: https://github.com/apache/kafka/pull/15416#discussion_r1500214172 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java: ## @@ -663,6 +663,7 @@ private void assignOwnedPartitions() {

[PR] KAFKA-16277: AbstractStickyAssignor - Sort owned TopicPartitions by p… [kafka]

2024-02-21 Thread via GitHub
credpath-seek opened a new pull request, #15416: URL: https://github.com/apache/kafka/pull/15416 ## Context Treats `KAFKA-16277 - CooperativeStickyAssignor does not spread topics evenly among consumer group` https://issues.apache.org/jira/browse/KAFKA-16277 Tests WIP