Hi all Iam currently using kafka 0.8.2.1 consumer which has kafka java api consumer but I had to upgrade to kafka 0.8.2.3 and when I add the jars for kafka 0.8.2.3 my consumer code doesn't compile. consumerConnector = ConsumerConfig .createJavaConsumerConnector(consumerConfig);
Do I have to rewrite the whole consumer to use the new jar. Whats the best way forward please? Regards Surender Kudumula