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?