[jira] [Updated] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness (part 7)

[ https://issues.apache.org/jira/browse/KAFKA-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8510: --- Component/s: consumer > Update StreamsPartitionAssignor to use the built-in owned partitions to >

[jira] [Commented] (KAFKA-8106) Reducing the allocation and copying of ByteBuffer when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864532#comment-16864532 ] Guozhang Wang commented on KAFKA-8106: -- Okay guys after some further benchmarks now I think I've

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864496#comment-16864496 ] ASF GitHub Bot commented on KAFKA-8179: --- guozhangwang commented on pull request #6528: KAFKA-8179:

[jira] [Updated] (KAFKA-8494) Refactor Consumer#StickyAssignor and add CooperativeStickyAssignor (part 4)

[ https://issues.apache.org/jira/browse/KAFKA-8494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8494: --- Summary: Refactor Consumer#StickyAssignor and add CooperativeStickyAssignor (part 4)

[jira] [Commented] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

[ https://issues.apache.org/jira/browse/KAFKA-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864423#comment-16864423 ] ASF GitHub Bot commented on KAFKA-8456: --- mjsax commented on pull request #6941: KAFKA-8456:

[jira] [Closed] (KAFKA-4048) Connect does not support RetriableException consistently for sinks

[ https://issues.apache.org/jira/browse/KAFKA-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava closed KAFKA-4048. > Connect does not support RetriableException consistently for sinks >

[jira] [Created] (KAFKA-8541) Flakey test LeaderElectionCommandTest#testTopicPartition

Boyang Chen created KAFKA-8541: -- Summary: Flakey test LeaderElectionCommandTest#testTopicPartition Key: KAFKA-8541 URL: https://issues.apache.org/jira/browse/KAFKA-8541 Project: Kafka Issue

[jira] [Assigned] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

[ https://issues.apache.org/jira/browse/KAFKA-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8456: -- Assignee: Matthias J. Sax > Flaky Test >

[jira] [Commented] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

[ https://issues.apache.org/jira/browse/KAFKA-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864354#comment-16864354 ] Matthias J. Sax commented on KAFKA-8456:

[jira] [Commented] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864353#comment-16864353 ] Matthias J. Sax commented on KAFKA-8108:

[jira] [Created] (KAFKA-8540) Improve InsertField connect transform to allow inserting processed timestamp

Khushal Kumthekar created KAFKA-8540: Summary: Improve InsertField connect transform to allow inserting processed timestamp Key: KAFKA-8540 URL: https://issues.apache.org/jira/browse/KAFKA-8540

[jira] [Assigned] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

[ https://issues.apache.org/jira/browse/KAFKA-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8452: -- Assignee: John Roesler > Possible Suppress buffer optimization: de-duplicate prior

[jira] [Commented] (KAFKA-8488) FetchSessionHandler logging create 73 mb allocation in TLAB which could be no op

[ https://issues.apache.org/jira/browse/KAFKA-8488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864233#comment-16864233 ] ASF GitHub Bot commented on KAFKA-8488: --- cmccabe commented on pull request #6890: KAFKA-8488:

[jira] [Commented] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

[ https://issues.apache.org/jira/browse/KAFKA-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864194#comment-16864194 ] ASF GitHub Bot commented on KAFKA-8452: --- vvcephei commented on pull request #6940: KAFKA-8452:

[jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864184#comment-16864184 ] Jun Rao commented on KAFKA-8532: [~lbdai3190], expiryScheduler.shutdown() is probably not the issue. That

[jira] [Resolved] (KAFKA-8530) Consumer should handle authorization errors in OffsetFetch

[ https://issues.apache.org/jira/browse/KAFKA-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8530. Resolution: Fixed Fix Version/s: 2.4.0 > Consumer should handle authorization

[jira] [Commented] (KAFKA-8530) Consumer should handle authorization errors in OffsetFetch

[ https://issues.apache.org/jira/browse/KAFKA-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864181#comment-16864181 ] ASF GitHub Bot commented on KAFKA-8530: --- hachikuji commented on pull request #6928: KAFKA-8530;

[jira] [Commented] (KAFKA-6874) Add Configuration Allowing for Optional Topology Optimization

[ https://issues.apache.org/jira/browse/KAFKA-6874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864155#comment-16864155 ] Bill Bejeck commented on KAFKA-6874: [~mjsax] resolved as duplicate, let me know if there is anything

[jira] [Resolved] (KAFKA-6874) Add Configuration Allowing for Optional Topology Optimization

[ https://issues.apache.org/jira/browse/KAFKA-6874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6874. Resolution: Duplicate Fix Version/s: 2.0.0 Duplicate of 

[jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864136#comment-16864136 ] Ismael Juma commented on KAFKA-8532: Thanks for the report. Can you reproduce this with 2.2.1 or

[jira] [Assigned] (KAFKA-8526) Broker may select a failed dir for new replica even in the presence of other live dirs

[ https://issues.apache.org/jira/browse/KAFKA-8526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Soarez reassigned KAFKA-8526: -- Assignee: Igor Soarez > Broker may select a failed dir for new replica even in the presence

[jira] [Commented] (KAFKA-8183) Trogdor - ProduceBench should retry on UnknownTopicOrPartitionException during topic creation

[ https://issues.apache.org/jira/browse/KAFKA-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16863827#comment-16863827 ] Stanislav Kozlovski commented on KAFKA-8183: [https://github.com/apache/kafka/pull/6937] 

[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16863719#comment-16863719 ] chengxl commented on KAFKA-7304: Hi,Yu Yang..Is there any solution to this memory leak problem in