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

2020-07-12 Thread GitBox
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 @guozh

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

2020-07-12 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156368#comment-17156368 ] Guozhang Wang commented on KAFKA-10134: --- [~zhowei] Just to clarify are you working

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

2020-07-12 Thread GitBox
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 up

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

2020-07-12 Thread GitBox
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 boolea

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

2020-07-12 Thread jiamei xie (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156492#comment-17156492 ] jiamei xie commented on KAFKA-10136: I wrote one implement for multiple-thread, Muti

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

2020-07-12 Thread GitBox
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 implemen

[jira] [Updated] (KAFKA-10044) Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerToConfig

2020-07-12 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-10044: --- Summary: Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerTo