[GitHub] [kafka] abbccdda opened a new pull request #9012: A broker to controller channel manager for AlterConfig redirection

abbccdda opened a new pull request #9012: URL: https://github.com/apache/kafka/pull/9012 Co-authored-by: Viktor Somogyi viktorsomo...@gmail.com Co-authored-by: Boyang Chen boy...@confluent.io ### Committer Checklist (excluded from commit message) - [ ] Verify design and

[jira] [Commented] (KAFKA-10136) Make option threads of ConsumerPerformance work

[ https://issues.apache.org/jira/browse/KAFKA-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156492#comment-17156492 ] jiamei xie commented on KAFKA-10136: I wrote one implement for multiple-thread,

[GitHub] [kafka] guozhangwang commented on a change in pull request #8997: MINOR: Improve log4j for per-consumer assignment

guozhangwang commented on a change in pull request #8997: URL: https://github.com/apache/kafka/pull/8997#discussion_r453353080 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java ## @@ -1078,6 +1098,8 @@ private

[jira] [Commented] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156368#comment-17156368 ] Guozhang Wang commented on KAFKA-10134: --- [~zhowei] Just to clarify are you working with [~seanguo]

[GitHub] [kafka] guozhangwang opened a new pull request #9011: KAFKA-10134: Still depends on existence of any fetchable partitions to block on join

guozhangwang opened a new pull request #9011: URL: https://github.com/apache/kafka/pull/9011 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including

[GitHub] [kafka] ttapjinda commented on pull request #9006: KAFKA-3370 nearest offset reset

ttapjinda commented on pull request #9006: URL: https://github.com/apache/kafka/pull/9006#issuecomment-657202648 This is quite old ticket, we have implemented similar feature and used inside Agoda for a while. so we decided to open a pr here as well. Could you help with the review

[GitHub] [kafka] JoelWee commented on pull request #8923: KAFKA-6435: KIP-623 Add internal topics option to streamResetter

JoelWee commented on pull request #8923: URL: https://github.com/apache/kafka/pull/8923#issuecomment-657181993 @abbccdda rebased :) This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Comment Edited] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156214#comment-17156214 ] Jerry Wei edited comment on KAFKA-10134 at 7/12/20, 6:29 AM: - [~guozhang], I

[jira] [Commented] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156214#comment-17156214 ] Jerry Wei commented on KAFKA-10134: --- [~guozhang], I have three brokers and 10 consumers. When I