You could use a broker list or a VIP to deal with broker failures. Thanks,
Jun On Thu, Oct 10, 2013 at 10:50 PM, hsy...@gmail.com <hsy...@gmail.com> wrote: > Hi guys, > > I'm trying to maintain a bunch of simple kafka consumer to consume messages > from brokers. I know there is a way to send TopicMetadataRequest to broker > and get the response from the broker. But you have to specify the broker > list to query the information. But broker might not be available because of > some failure. My question is is there any api I can call and query broker > metadata for topic/partition directly from zookeeper? I know I can query > that information using zookeeper API. But that's not friendly datastructure > like the TopicMetadata/PartitionMetadata. Thank you! > > Best, > Siyuan >
