KafkaAdminClient#listOffsets should query by partition dimension

 

listOffsets接口查询 TopicPartition分区Offset的时候,  正常来说应该是按照分区维度来查询的

 

比如 我查询了 Topic1-0  、Topic1-1 ; 返回对应的数据。

 

正常情况下是这样没错，但是在调用这个接口之前 先调用了 Metadata接口。

 

并且在处理Metadata返回数据的时候，判断了如果对应的Topic有一个Topic分区leader不存在。都会抛出异常。如下：

 

 

 

 

 

假设这种情况：

 

Topic1 有3个分区； Topic1-0;Topic1-1; Topic1-2 ;

 

但是刚好 Topic1-2 这个分区由于某些原因导致分区Leader = -1

 

这个时候我想去查询  Topic1-0;Topic1-1; 这两个分区的Offset的时候，它直接给我抛出来异常了

 

正常逻辑，我这里没有涉及到有问题的Topic1-2；  我应该是能够查询出来数据的。

 

但是却给我异常了，这非常的不友好。