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
Issue Type: Improvement
Components: admin
Affects Versions: 2.7.2
Reporter: shizhenzhen
Attachments: image-2022-10-24-16-18-01-418.png,
image-2022-10-24-16-20-31-778.png
listOffsets接口查询 TopicPartition分区Offset的时候, 正常来说应该是按照分区维度来查询的
比如 我查询了 Topic1-0 、Topic1-1 ; 返回对应的数据。
正常情况下是这样没错,但是在调用这个接口之前 先调用了 Metadata接口。
并且在处理Metadata返回数据的时候,判断了如果对应的Topic有一个Topic分区leader不存在。都会抛出异常。如下:
!image-2022-10-24-16-20-31-778.png!
!image-2022-10-24-16-18-01-418.png!
假设这种情况:
Topic1 有3个分区; Topic1-0;Topic1-1; Topic1-2 ;
但是刚好 Topic1-2 这个分区由于某些原因导致分区Leader = -1
这个时候我想去查询 Topic1-0;Topic1-1; 这两个分区的Offset的时候,它直接给我抛出来异常了
正常逻辑,我这里没有涉及到有问题的Topic1-2; 我应该是能够查询出来数据的。
但是却给我异常了,这非常的不友好。
--
This message was sent by Atlassian Jira
(v8.20.10#820010)