Hi All

I have a requirement where based on the kafka version or compatible api in
the

 broker , we will be dynamically loading the best suited kafka client jar.
I bumped into

ApiVersionRequest and ApiVersionResponse and even went through some code to

in NetworkClient class , but I was not able to find any expilicit Api's in
the client

which could determine whether it is compatible with kafka broker it needs
to

communicate . Any pointers regarding this would be greatly appreciated.

Regards
Hari

Reply via email to