[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624947#comment-17624947 ] shizhenzhen commented on KAFKA-14328: - PR:  https://github.com/apache/kafka/pull/12793 >

[jira] [Commented] (KAFKA-14329) KafkaAdminClient#listOffsets should query by partition dimension

[ https://issues.apache.org/jira/browse/KAFKA-14329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623054#comment-17623054 ] shizhenzhen commented on KAFKA-14329: - 对于这里的异常 ，我觉得没有必只要有分区异常就抛出来，而是应该判断查询的分区有异常的话就抛出来。  

[jira] [Updated] (KAFKA-14329) KafkaAdminClient#listOffsets should query by partition dimension

[ https://issues.apache.org/jira/browse/KAFKA-14329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14329: Attachment: image-2022-10-24-16-47-03-180.png > KafkaAdminClient#listOffsets should query by

[jira] [Created] (KAFKA-14329) KafkaAdminClient#listOffsets should query by partition dimension

shizhenzhen created KAFKA-14329: --- Summary: KafkaAdminClient#listOffsets should query by partition dimension Key: KAFKA-14329 URL: https://issues.apache.org/jira/browse/KAFKA-14329 Project: Kafka

[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14328: Attachment: image-2022-10-24-14-48-27-907.png > KafkaAdminClient should be Changing the exception

[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622984#comment-17622984 ] shizhenzhen commented on KAFKA-14328: - [~dengziming] [~showuon]      超时的时候

[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14328: Attachment: image-2022-10-24-14-47-30-641.png > KafkaAdminClient should be Changing the exception

[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14328: Attachment: image-2022-10-24-14-28-10-365.png > KafkaAdminClient should be Changing the exception

[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622140#comment-17622140 ] shizhenzhen commented on KAFKA-14328: - 如果是发生请求的时候 导致的超时，代码里面或许是会把超时时候的异常给打印出来。   但是 PendingCall 

[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14328: Attachment: image-2022-10-21-16-58-19-353.png > KafkaAdminClient should be Changing the exception

[jira] [Comment Edited] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622136#comment-17622136 ] shizhenzhen edited comment on KAFKA-14328 at 10/21/22 8:56 AM: --- [~showuon] 

[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622136#comment-17622136 ] shizhenzhen commented on KAFKA-14328: - [~showuon]   感谢回复, 像你说的一样，我们期望通过重试能够解决这个异常，但是如果超时时间范围内不能够解决呢？

[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14328: Attachment: image-2022-10-21-16-54-40-588.png > KafkaAdminClient should be Changing the exception

[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14328: Attachment: image-2022-10-21-14-56-31-753.png Description:     KafkaAdminClient 的一些日志全部是

[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621468#comment-17621468 ] shizhenzhen commented on KAFKA-14328: - [~guozhang]    > KafkaAdminClient should be Changing the

[jira] [Created] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

shizhenzhen created KAFKA-14328: --- Summary: KafkaAdminClient should be Changing the exception level When an exception occurs Key: KAFKA-14328 URL: https://issues.apache.org/jira/browse/KAFKA-14328

[jira] [Commented] (KAFKA-13834) batch drain for nodes might have starving issue

[ https://issues.apache.org/jira/browse/KAFKA-13834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524687#comment-17524687 ] shizhenzhen commented on KAFKA-13834: - [~guozhang] [~showuon]    Done! Thanks！ > batch drain for

[jira] [Updated] (KAFKA-13834) batch drain for nodes might have starving issue

[ https://issues.apache.org/jira/browse/KAFKA-13834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-13834: Description: h3. 问题代码 problem code RecordAccumulator#drainBatchesForOneNode

[jira] [Updated] (KAFKA-13834) batch drain for nodes might have starving issue

[ https://issues.apache.org/jira/browse/KAFKA-13834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-13834: Summary: batch drain for nodes might have starving issue (was: Some problems with producers

[jira] [Created] (KAFKA-13834) Some problems with producers choosing batches of messages to send

shizhenzhen created KAFKA-13834: --- Summary: Some problems with producers choosing batches of messages to send Key: KAFKA-13834 URL: https://issues.apache.org/jira/browse/KAFKA-13834 Project: Kafka

[jira] [Comment Edited] (KAFKA-13226) Partition expansion may cause uneven distribution

[ https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435380#comment-17435380 ] shizhenzhen edited comment on KAFKA-13226 at 11/1/21, 2:40 AM: --- I hava

[jira] [Comment Edited] (KAFKA-13226) Partition expansion may cause uneven distribution

[ https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435384#comment-17435384 ] shizhenzhen edited comment on KAFKA-13226 at 10/28/21, 1:03 PM: When I

[jira] [Comment Edited] (KAFKA-13226) Partition expansion may cause uneven distribution

[ https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435384#comment-17435384 ] shizhenzhen edited comment on KAFKA-13226 at 10/28/21, 1:02 PM: When I

[jira] [Commented] (KAFKA-13226) Partition expansion may cause uneven distribution

[ https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435384#comment-17435384 ] shizhenzhen commented on KAFKA-13226: - When I tried to repair it, I found that even if I repaired

[jira] [Commented] (KAFKA-13226) Partition expansion may cause uneven distribution

[ https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435385#comment-17435385 ] shizhenzhen commented on KAFKA-13226: - 我在尝试修复它的时候,

[jira] [Commented] (KAFKA-13226) Partition expansion may cause uneven distribution

[ https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435380#comment-17435380 ] shizhenzhen commented on KAFKA-13226: - I hava push  a PR, please review it

[jira] [Updated] (KAFKA-13226) Partition expansion may cause uneven distribution

[ https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-13226: Affects Version/s: 2.8.1 3.0.0 > Partition expansion may cause uneven

[jira] [Updated] (KAFKA-13226) Partition expansion may cause uneven distribution

[ https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-13226: Reviewer: Guozhang Wang (was: Zhanxiang (Patrick) Huang) > Partition expansion may cause uneven

[jira] [Created] (KAFKA-13226) Partition expansion may cause uneven distribution

shizhenzhen created KAFKA-13226: --- Summary: Partition expansion may cause uneven distribution Key: KAFKA-13226 URL: https://issues.apache.org/jira/browse/KAFKA-13226 Project: Kafka Issue Type: