[jira] [Comment Edited] (KAFKA-16361) Rack aware sticky assignor minQuota violations

[ https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846139#comment-17846139 ] li xiangyuan edited comment on KAFKA-16361 at 5/14/24 2:39 AM: --- and I also

[jira] [Comment Edited] (KAFKA-16361) Rack aware sticky assignor minQuota violations

[ https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846139#comment-17846139 ] li xiangyuan edited comment on KAFKA-16361 at 5/14/24 2:39 AM: --- and I also

[jira] [Comment Edited] (KAFKA-16361) Rack aware sticky assignor minQuota violations

[ https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846139#comment-17846139 ] li xiangyuan edited comment on KAFKA-16361 at 5/14/24 2:39 AM: --- and I also

[jira] [Commented] (KAFKA-16361) Rack aware sticky assignor minQuota violations

[ https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846139#comment-17846139 ] li xiangyuan commented on KAFKA-16361: -- and I also create a[ Jira

[jira] [Commented] (KAFKA-16361) Rack aware sticky assignor minQuota violations

[ https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846133#comment-17846133 ] li xiangyuan commented on KAFKA-16361: -- please check this [pr

[jira] [Resolved] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan resolved KAFKA-15106. -- Resolution: Fixed > AbstractStickyAssignor may stuck in 3.5 >

[jira] [Updated] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-15106: - Fix Version/s: 3.6.0 > AbstractStickyAssignor may stuck in 3.5 >

[jira] [Commented] (KAFKA-15170) CooperativeStickyAssignor cannot adjust assignment correctly

[ https://issues.apache.org/jira/browse/KAFKA-15170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742361#comment-17742361 ] li xiangyuan commented on KAFKA-15170: -- please note another bugs in this implementation. the

[jira] [Updated] (KAFKA-15170) CooperativeStickyAssignor cannot adjust assignment correctly

[ https://issues.apache.org/jira/browse/KAFKA-15170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-15170: - Description: AbstractStickyAssignor use ConstrainedAssignmentBuilder to build assignment when

[jira] [Created] (KAFKA-15170) CooperativeStickyAssignor cannot adjust assignment correctly

li xiangyuan created KAFKA-15170: Summary: CooperativeStickyAssignor cannot adjust assignment correctly Key: KAFKA-15170 URL: https://issues.apache.org/jira/browse/KAFKA-15170 Project: Kafka

[jira] [Assigned] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan reassigned KAFKA-15106: Assignee: li xiangyuan > AbstractStickyAssignor may stuck in 3.5 >

[jira] [Commented] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736971#comment-17736971 ] li xiangyuan commented on KAFKA-15106: -- I deem the root cause is the check `isBalanced` have some

[jira] [Commented] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736830#comment-17736830 ] li xiangyuan commented on KAFKA-15106: -- [~rajinisiva...@gmail.com]  I notice you are the writer,

[jira] [Commented] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736829#comment-17736829 ] li xiangyuan commented on KAFKA-15106: -- I wonder whether modify the line in function `isBalanced`

[jira] [Updated] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-15106: - Description: this could reproduce in ut easy, just int

[jira] [Updated] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-15106: - Due Date: 19/Jun/23 (was: 14/Apr/23) > AbstractStickyAssignor may stuck in 3.5 >

[jira] [Created] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

li xiangyuan created KAFKA-15106: Summary: AbstractStickyAssignor may stuck in 3.5 Key: KAFKA-15106 URL: https://issues.apache.org/jira/browse/KAFKA-15106 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-15106: - Description: this could reproduce in ut easy, just int

[jira] [Updated] (KAFKA-15106) AbstractStickyAssignor may stuck in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-15106: - Description: this could reproduce in ut easily, just int

[jira] [Commented] (KAFKA-14914) binarySearch in AbstactIndex may execute with infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-14914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720372#comment-17720372 ] li xiangyuan commented on KAFKA-14914: -- After create this jira ticket we had encountered this

[jira] [Created] (KAFKA-14914) binarySearch in AbstactIndex may execute with infinite loop

li xiangyuan created KAFKA-14914: Summary: binarySearch in AbstactIndex may execute with infinite loop Key: KAFKA-14914 URL: https://issues.apache.org/jira/browse/KAFKA-14914 Project: Kafka

[jira] [Assigned] (KAFKA-14901) Flaky test ExactlyOnceSourceIntegrationTest.testConnectorReconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-14901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan reassigned KAFKA-14901: Assignee: (was: li xiangyuan) > Flaky test

[jira] [Assigned] (KAFKA-14901) Flaky test ExactlyOnceSourceIntegrationTest.testConnectorReconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-14901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan reassigned KAFKA-14901: Assignee: li xiangyuan > Flaky test

[jira] [Commented] (KAFKA-9648) kafka server should resize backlog when create serversocket

[ https://issues.apache.org/jira/browse/KAFKA-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053195#comment-17053195 ] li xiangyuan commented on KAFKA-9648: - [~junrao]: Yes 1412 is quite small, I have noticed that but

[jira] [Commented] (KAFKA-9648) kafka server should resize backlog when create serversocket

[ https://issues.apache.org/jira/browse/KAFKA-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051780#comment-17051780 ] li xiangyuan commented on KAFKA-9648: - [~junrao]:  all our kafka server have the same tcp

[jira] [Created] (KAFKA-9648) kafka server should resize backlog when create serversocket

li xiangyuan created KAFKA-9648: --- Summary: kafka server should resize backlog when create serversocket Key: KAFKA-9648 URL: https://issues.apache.org/jira/browse/KAFKA-9648 Project: Kafka

[jira] [Created] (KAFKA-9646) kafka consumer cause high cpu usage

li xiangyuan created KAFKA-9646: --- Summary: kafka consumer cause high cpu usage Key: KAFKA-9646 URL: https://issues.apache.org/jira/browse/KAFKA-9646 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 may cause tcp delay ack(Congestion Control)

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-9211: Summary: kafka upgrade 2.3.0 may cause tcp delay ack(Congestion Control) (was: kafka upgrade

[jira] [Commented] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989369#comment-16989369 ] li xiangyuan commented on KAFKA-9211: - After some test, I believe we have successfully reproduced

[jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-9211: Attachment: nodelay.txt > kafka upgrade 2.3.0 cause produce speed decrease >

[jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-9211: Attachment: ackdelay.txt > kafka upgrade 2.3.0 cause produce speed decrease >

[jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-9211: Attachment: producer.node.latency.png > kafka upgrade 2.3.0 cause produce speed decrease >

[jira] [Created] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

li xiangyuan created KAFKA-9211: --- Summary: kafka upgrade 2.3.0 cause produce speed decrease Key: KAFKA-9211 URL: https://issues.apache.org/jira/browse/KAFKA-9211 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1448) Filter-plugins for messages

[ https://issues.apache.org/jira/browse/KAFKA-1448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914900#comment-16914900 ] li xiangyuan commented on KAFKA-1448: - hi since kafka now support for add heads to message ,I think