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
You need to set the serializer to StringEncoder. See
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example

Thanks,

Jun
On Tue, Aug 27, 2013 at 1:34 PM, Robert Heise <[EMAIL PROTECTED]>wrote:

> 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