[
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 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
> Priority: Major
> Labels: bug
> Attachments: image-2022-10-24-16-18-01-418.png,
> image-2022-10-24-16-20-31-778.png, image-2022-10-24-16-47-03-180.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)
