Hi Joe,
I am trying to setup a Kafka Simple Consumer in java. I am using the
kafka.consumer.Consumer.createJavaConsumerConnector to create a consumer
connector. The connector is used for get message streams. I am using
"kafka.javaapi.consumer.ConsumerConnector"
*Code: *
import kafka.consumer.*;
import kafka.javaapi.consumer.ConsumerConnector;
*ConsumerConnector consumerConnector =
Consumer.createJavaConsumerConnector(getConsumerConfig());*
Map<String,Integer> topicCountMap = new HashMap<String, Integer>();
topicCountMap.put(topic, 1);
Map<String, List<KafkaStream<byte[], byte[]>>> topicStreamMap =
consumerConnector.createMessageStreams(topicCountMap);
*My maven dependency reads as *
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
<version>0.8.0</version>
</dependency>
*JRE version: 1.6*
*The error I am getting is *
testHasNext(com.walmartlabs.mupd8.KafkaSourceTest) Time elapsed: 0.851 sec
<<< ERROR!
java.lang.UnsupportedClassVersionError:
kafka/javaapi/consumer/ConsumerConnector : Unsupported major.minor version
51.0
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClassCond(ClassLoader.java:637)
at java.lang.ClassLoader.defineClass(ClassLoader.java:621)
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:283)
at java.net.URLClassLoader.access$000(URLClassLoader.java:58)
at java.net.URLClassLoader$1.run(URLClassLoader.java:197)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
at kafka.consumer.Consumer.createJavaConsumerConnector(Unknown Source)
at com.walmartlabs.mupd8.KafkaSource.getIterator(KafkaSource.java:111)
at com.walmartlabs.mupd8.KafkaSource.initialize(KafkaSource.java:143)
On Thu, Jan 23, 2014 at 12:05 PM, Joe Stein <[email protected]> wrote:
> It would be helpful if you can reproduce the issue.
>
> /*******************************************
> Joe Stein
> Founder, Principal Consultant
> Big Data Open Source Security LLC
> http://www.stealth.ly
> Twitter: @allthingshadoop
> ********************************************/
>
>
> On Jan 22, 2014, at 11:22 PM, Joe Stein <[email protected]> wrote:
>
> > Can you share your reference?
> >
> >
> > /*******************************************
> > Joe Stein
> > Founder, Principal Consultant
> > Big Data Open Source Security LLC
> > http://www.stealth.ly
> > Twitter: @allthingshadoop
> > ********************************************/
> >
> >
> > On Jan 22, 2014, at 10:36 PM, Abhinav Anand <[email protected]> wrote:
> >
> >> Hi Joe,
> >> I am using jre 1.6 and I don't see any reason for the error. But I am
> >> still getting the exception while running the consumer with jre 6. It
> runs
> >> fine with jre 7
> >>
> >> Regards,
> >> Abhinav
> >>
> >>
> >> On Thu, Jan 23, 2014 at 3:57 AM, Joe Stein <[email protected]>
> wrote:
> >>
> >>> 0.8.0 final release was built with JDK 6 (which was RC5)
> >>>
> >>> /*******************************************
> >>> Joe Stein
> >>> Founder, Principal Consultant
> >>> Big Data Open Source Security LLC
> >>> http://www.stealth.ly
> >>> Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
> >>> ********************************************/
> >>>
> >>>
> >>> On Wed, Jan 22, 2014 at 5:16 PM, Abhinav Anand <[email protected]>
> wrote:
> >>>
> >>>> I am using jre 1.6.
> >>>>
> >>>> All the release candidates were built against 1.7. was the final
> release
> >>>> also built against 1.7 ?
> >>>>
> >>>>
> >>>> On Thu, Jan 23, 2014 at 3:25 AM, Abhinav Anand <[email protected]>
> >>> wrote:
> >>>>
> >>>>> Hi,
> >>>>> I have kafka_2.10 version 0.8.0 in my maven dependency. I am trying
> to
> >>>>> run a consumer. It is throwing major.minor version error.
> >>>>>
> >>>>> *java.lang.UnsupportedClassVersionError:
> >>>>> kafka/javaapi/consumer/ConsumerConnector : Unsupported major.minor
> >>>> version
> >>>>> 51.0*
> >>>>>
> >>>>> Is the Kafka repo built against jdk 1.7?
> >>>>>
> >>>>> --
> >>>>> Abhinav Anand
> >>>>>
> >>>>
> >>>>
> >>>>
> >>>> --
> >>>> Abhinav Anand
> >>>>
> >>>
> >>
> >>
> >>
> >> --
> >> Abhinav Anand
>
--
Abhinav Anand
