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
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

 
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