Hi Team, We are using KafkaConsumer.partitionsFor() API to find the list of available partitions. After fetching the list of partitions, We use Consumer.offsetsForTimes() API to find the offsets for a given timestamp.
The API Consumer.partitionsFor() simply returning all partitions including the partitions which the leader is set to -1. It's causing an issue (Timeout Exception) when we call Consumer.offsetsForTimes() API. I'm planning to use adminClient.describeTopics(list).all().get(); And filter only the partitions which are healthy. Will there be any performance impact of using AdminClient? Kafka Version: 2.4.1 Kafka Client: 2.3.0 --Senthil
