I think it is possible to infer a version based on a remote broker's response to various newer api methods. I wrote some probes in python that check ListGroups for 0.9, GroupCoordinatorRequest for 0.8.2, OffsetFetchRequest for 0.8.1, and MetadataRequest for 0.8.0. It seems to work well enough.
Also, this is related to KIP 35: https://cwiki.apache.org/confluence/display/KAFKA/KIP-35+-+Retrieving+protocol+version -Dana On Feb 4, 2016 8:28 PM, "Manikumar Reddy" <ku...@nmsworks.co.in> wrote: > Currently it is available through JMX Mbean. It is not available on wire > protocol/requests. > > Pending JIRAs related to this: > https://issues.apache.org/jira/browse/KAFKA-2061 > > On Fri, Feb 5, 2016 at 4:31 AM, <ma...@kafkatool.com> wrote: > > > Is there a way to detect the broker version (even at a high level 0.8 vs > > 0.9) using the kafka-clients Java library? > > > > -- > > Best regards, > > Marko > > www.kafkatool.com > > > > >
