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)

Reply via email to