Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Help getting started


Copy link to this message
-
Re: Help getting started
Thanks Joe for the response.

I've tried the beta1 binary distribution as well.  Here is the steps I am taking:

* Downloaded kafka_2.8.0-0.8.0-beta1
* Imported jar files to eclipse project:
- kafka_2.8.0-0.8.0-beta1/kafka_2.8.0-0.8.0-beta1.jar
- added kafka_2.8.0-0.8.0-beta1/libs/*.* to build path
* Quick unit test for producer
@Test
public void test() {
Producer<String, String> producer = new Producer<String, String>(config);
KeyedMessage<String, String> data = new KeyedMessage<String, String>("H406", "test", "test");
}

What am I missing?

________________________________
 From: Joe Stein <[EMAIL PROTECTED]>
To: "[EMAIL PROTECTED]" <[EMAIL PROTECTED]>
Sent: Tuesday, August 27, 2013 3:31 PM
Subject: Re: Help getting started
 

You can use the binary distribution if you like https://dist.apache.org/repos/dist/release/kafka/kafka_2.8.0-0.8.0-beta1.tgz

As far as what is causing the error will need more info can you maybe take
 everything going on (commands/steps being done and the output) in your terminal and gist it. 
/*******************************************
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http://www.stealth.ly
Twitter: @allthingshadoop
********************************************/
On Aug 27, 2013, at 2:53 PM, Robert Heise <[EMAIL PROTECTED]> wrote:

> Hello,
>
> I have to no avail.  Im still getting the same exception:
>
> java.lang.ClassNotFoundException:
> at java.lang.Class.forName0(Native Method)
> at java.lang.Class.forName(Class.java:171)
> at kafka.utils.Utils$.createObject(Utils.scala:457)
> at kafka.producer.Producer.<init>(Producer.scala:59)
> at
 kafka.javaapi.producer.Producer.<init>(Producer.scala:25)
> at kafka.PublisherTest.test(PublisherTest.java:56)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
> at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
> at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> at
 org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
> at
 org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:467)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:683)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:390)
> at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:197)
>
>
>
> ________________________________
> From: Joe Stein <[EMAIL PROTECTED]>
> To: [EMAIL PROTECTED]; Robert Heise <[EMAIL PROTECTED]>
> Sent: Tuesday, August 27, 2013 2:40
 PM
> Subject: Re: Help getting started
 java.lang.ClassNotFoundException:
 org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
 org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
 at
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB