Kafka, mail # user - Re: Help getting started - 2013-08-27, 20:34
 Search Hadoop and all its subprojects:

Switch to Threaded View
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:

 kafka.javaapi.producer.Producer.<init>(Producer.scala:25)
 org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
 org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
 PM
 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