How to use ApiVersionRequest and ApiVersionResponse

2017-10-09 Thread Hari Krishna
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

Re: java.lang.NoSuchMethodError: scala.collection.GenTraversableOnce.$init

2017-10-09 Thread Hari Krishna
Hi Amy Could you check in your pom if any other dependencies defined in the pom is downloading different version of scala-library jar?. Any chance you are running kafka from eclipse?. If so sometimes if you are using scala from eclipse once u add scala nature it inherently picks up its own version

How to use ApiVersionRequest and ApiVersionResponse

2017-10-09 Thread Hari Krishna
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