Re: Creating a Consumer Thread Pool

one-jar onejar-maven-plugin.googlecode.com http://onejar-maven-plugin.googlecode.com/svn/mavenrepo

Creating a Consumer Thread Pool

Hi all, I checked out the java source and looked at the java examples. They worked well in my IDE and on the console. However, I also tried the threaded example following the consumer group example. The problem is, this example is not working and toString on the stream iterator returns the

Re: Runtime problem in 8 beta1?

p://www.stealth.ly > Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> >****/ > > >On Tue, Aug 27, 2013 at 2:24 PM, David Williams >wrote: > >> All, >> >> Sorry for this continued thread,

Re: Runtime problem in 8 beta1?

:77) at kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(Zook eeperConsumerConnector.scala:89) What is this? -- On 8/27/13 11:18 AM, "David Williams" wrote: >This resulted in > >Exception in thread "main" java.lang.reflect.InvocationTargetException >at sun.reflect.NativeMethod

Re: Runtime problem in 8 beta1?

> javax.jms >jms > > > > > > >On Tue, Aug 27, 2013 at 11:10 AM, David Williams >wrote: > >> >> So an update. The required version of log4j is >> >>

Re: Runtime problem in 8 beta1?

rConnector(ConsumerConnector.scal a:100) at kafka.consumer.Consumer.createJavaConsumerConnector(ConsumerConnector.scala ) Please explain whats going on here. -- On 8/27/13 11:10 AM, "David Williams" wrote: > >So an update. The required version of log4j is > > > log4j >

Re: Runtime problem in 8 beta1?

r.java:630) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 12 more -- On 8/27/13 9:54 AM, "David Williams" wrote: >Ok great, thanks. What are the other required dependencies? > > >For exmaple, log4j seems needed: > > >Caused by: j

Re: Runtime problem in 8 beta1?

.2 so your Scala version should be >2.9.2 > > > >/*** > Joe Stein > Founder, Principal Consultant > Big Data Open Source Security LLC > http://www.stealth.ly > Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> >******

Re: Runtime problem in 8 beta1?

che.org/jira/browse/KAFKA-717 > > >/*** > Joe Stein > Founder, Principal Consultant > Big Data Open Source Security LLC > http://www.stealth.ly > Twitter: @allthingshadoop >********/ > > &

Re: Runtime problem in 8 beta1?

>Nothing complex here, you just don't have the the scala library on your >classpath. It works just like any jar--if there is a dependency on classes >in the jar it needs to be on the classpath. > > >On Mon, Aug 26, 2013 at 7:10 PM, David Williams >wrote: > >> Hi al

Runtime problem in 8 beta1?

Hi all, First let me say I have detailed the description of the issue I have in an Stack Overflow Ticket here: http://stackoverflow.com/questions/18455480/kafka-quickstart-java-lang-noclassdeffounderror-scala-scalaobject I am trying to build a small prototype for a project in which I want to us