Home | About | Sematext search-lucene.com search-hadoop.com
 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