t; ,
> Senthil kumar
> *Cc: *"users@kafka.apache.org" , "
> senthilec...@apache.org"
> *Subject: *Re: KafkaConsumer.partitionsFor() Vs
> KafkaAdminClient.describeTopics()
>
>
>
> *[External]*
>
> Thanks Manoj. It works for me.
>
>
>
>
: Tuesday, May 5, 2020 at 12:06 PM
To: "Agrawal, Manoj (Cognizant)" , Senthil kumar
Cc: "users@kafka.apache.org" ,
"senthilec...@apache.org"
Subject: Re: KafkaConsumer.partitionsFor() Vs KafkaAdminClient.describeTopics()
[External]
Thanks Manoj.
Thanks Manoj. It works for me.
Looks to me the KafkaAdminClient (Singleton instance ) is faster than
Consumer.partitionsFor() API. In terms of performance which one is good to
fetch the metadata of a given topic. Thanks!
On Wed, May 6, 2020 at 12:26 AM wrote:
> I think you can filter list of
I think you can filter list of topic return by KafkaConsumer.partitionsFor()
on by using method type , if this is PartitionInfo.leader() then include
those partition in list .
On 5/5/20, 11:44 AM, "SenthilKumar K" wrote:
[External]
Hi Team, We are using
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
