Hi Sreeni, Using the SimpleConsumer you can send a TopicMetadataRequest for a topic and the TopicMetadataResponse will contain TopicMetadata for each topic requested (or all) which contains PartitionMetadata for all all partitions. The PartitionMetadata contains the leader, replicas, and isr.
Is that what you are looking for? Thanks, Grant On Mon, Aug 3, 2015 at 7:26 AM, Sreenivasulu Nallapati < sreenu.nallap...@gmail.com> wrote: > Hello, > > Is there a way that we can find the lead broker > from kafka.message.MessageAndMetadata class? > > My use case is simple, I have topic and partition and wanted to find out > the lead broker for that partition. > > Please provide your insights > > > Thanks > Sreeni > -- Grant Henke Software Engineer | Cloudera gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
