Thanks Jens. What I want to achieve is to check every broker within a cluster functions probably. The way you suggest can identify the liveness of a cluster but it doesn't necessarily mean every broker in the cluster is alive. In order to achieve that I can either create a topic with number of partitions being same as the number of brokers and min.insync.isr=number of brokers or one topic per broker and then send ping message to broker. But this approach is definitely not scalable as we expand the cluster. Therefore I am looking for a way to achieve this.
On Mon, 29 Feb 2016 at 16:54 Jens Rantil <jens.ran...@tink.se> wrote: > Hi, > > I assume you first want to ask yourself what liveness you would like to > check for. I guess the most realistic check is to put a "ping" message on > the broken and make sure that you can consume it. > > Cheers, > Jens > > On Fri, Feb 26, 2016 at 12:38 PM, tao xiao <xiaotao...@gmail.com> wrote: > > > Hi team, > > > > What is the best way to verify a specific Kafka node functions properly? > > Telnet the port is one of the approach but I don't think it tells me > > whether or not the broker can still receive/send traffics. I am thinking > to > > ask for metadata from the broker using consumer.partitionsFor. If it can > > return partitioninfo it is considered live. Is this a good approach? > > > > > > -- > Jens Rantil > Backend engineer > Tink AB > > Email: jens.ran...@tink.se > Phone: +46 708 84 18 32 > Web: www.tink.se > > Facebook <https://www.facebook.com/#!/tink.se> Linkedin > < > http://www.linkedin.com/company/2735919?trk=vsrp_companies_res_photo&trkInfo=VSRPsearchId%3A1057023381369207406670%2CVSRPtargetId%3A2735919%2CVSRPcmpt%3Aprimary > > > Twitter <https://twitter.com/tink> >
